Revision 46709
Added by Claudio Atzori almost 7 years ago
SolrIndexServerDAO.java | ||
---|---|---|
85 | 85 |
for (IndexConfigFactory.CONFIG_PARAMS param_Name : IndexConfigFactory.CONFIG_PARAMS.values()) { |
86 | 86 |
params.put(param_Name.toString(), p.get(param_Name.toString())); |
87 | 87 |
} |
88 |
params.put(IndexConfigFactory.CONFIG_PARAMS.indexDataDir.toString(), mdref.toString()); |
|
89 | 88 |
|
90 | 89 |
zkUtils.uploadZookeperConfig(server.getZkStateReader().getZkClient(), mdref.toString(), parse(fields), params, false); |
91 | 90 |
solrAdministrator.createSolrIndex(p.get("host"), p.get("port"), mdref.toString(), p.get("numShards"), p.get("replicationFactor"), |
92 |
mdref.toString()); |
|
91 |
mdref.toString(), p.get("maxShardsPerNode"));
|
|
93 | 92 |
} |
94 | 93 |
server.getZkStateReader().close(); |
95 | 94 |
|
... | ... | |
117 | 116 |
for (IndexConfigFactory.CONFIG_PARAMS param_Name : IndexConfigFactory.CONFIG_PARAMS.values()) { |
118 | 117 |
params.put(param_Name.toString(), getServiceProperties().get(param_Name.toString())); |
119 | 118 |
} |
120 |
params.put(IndexConfigFactory.CONFIG_PARAMS.indexDataDir.toString(), mdRef.toString()); |
|
119 |
|
|
121 | 120 |
zkUtils.uploadZookeperConfig(server.getZkStateReader().getZkClient(), mdRef.toString(), fields, params, true); |
122 | 121 |
server.getZkStateReader().close(); |
123 | 122 |
server.shutdown(); |
Also available in: Unified diff
integrated changes from dnet40: added support for create multiple shards for the same collection on the same solr server