org.apache.solr.client.solrj.impl.CloudSolrClient.setIdField()方法的使用及代码示例

本文整理了Java中org.apache.solr.client.solrj.impl.CloudSolrClient.setIdField()方法的一些代码示例，展示了CloudSolrClient.setIdField()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。CloudSolrClient.setIdField()方法的具体详情如下：
包路径：org.apache.solr.client.solrj.impl.CloudSolrClient
类名称：CloudSolrClient
方法名：setIdField

CloudSolrClient.setIdField介绍

暂无

代码示例

代码示例来源：origin: com.ngdata/hbase-indexer-mr

private DirectSolrInputDocumentWriter createCloudSolrWriter(
Context context, Map indexConnectionParams, String uniqueKeyField)
throws IOException {
String indexZkHost = indexConnectionParams.get(SolrConnectionParams.ZOOKEEPER);
String collectiOnName= indexConnectionParams.get(SolrConnectionParams.COLLECTION);
if (indexZkHost == null) {
throw new IllegalStateException("No index ZK host defined");
}
if (collectiOnName== null) {
throw new IllegalStateException("No collection name defined");
}
CloudSolrClient solrServer = new CloudSolrClient.Builder().withZkHost(indexZkHost).build();
int zkSessiOnTimeout= HBaseIndexerConfiguration.getSessionTimeout(context.getConfiguration());
solrServer.setZkClientTimeout(zkSessionTimeout);
solrServer.setZkConnectTimeout(zkSessionTimeout);
solrServer.setDefaultCollection(collectionName);
solrServer.setIdField(uniqueKeyField);
return new DirectSolrInputDocumentWriter(context.getConfiguration().get(INDEX_NAME_CONF_KEY), solrServer);
}

代码示例来源：origin: com.ngdata/hbase-indexer-engine

public static SolrClient createCloudSolrClient(Map connectionParameters, String uniqueKeyField, int zkSessionTimeout) {
String solrZk = connectionParameters.get(SolrConnectionParams.ZOOKEEPER);
CloudSolrClient solr = new CloudSolrClient.Builder().withZkHost(solrZk).build();
solr.setZkClientTimeout(zkSessionTimeout);
solr.setZkConnectTimeout(zkSessionTimeout);
String collection = connectionParameters.get(SolrConnectionParams.COLLECTION);
solr.setDefaultCollection(collection);
solr.setIdField(uniqueKeyField);
return solr;
}

代码示例来源：origin: com.ngdata/hbase-indexer-mr

private Set createSolrServers(Map indexConnectionParams, String uniqueKeyField) throws MalformedURLException {
String solrMode = getSolrMode(indexConnectionParams);
if (solrMode.equals("cloud")) {
String indexZkHost = indexConnectionParams.get(SolrConnectionParams.ZOOKEEPER);
String collectiOnName= indexConnectionParams.get(SolrConnectionParams.COLLECTION);
CloudSolrClient solrServer = new CloudSolrClient.Builder().withZkHost(indexZkHost).build();
int zkSessiOnTimeout= HBaseIndexerConfiguration.getSessionTimeout(getConf());
solrServer.setZkClientTimeout(zkSessionTimeout);
solrServer.setZkConnectTimeout(zkSessionTimeout);
solrServer.setDefaultCollection(collectionName);
solrServer.setIdField(uniqueKeyField);
return Collections.singleton((SolrClient)solrServer);
} else if (solrMode.equals("classic")) {
PoolingClientConnectionManager cOnnectionManager= new PoolingClientConnectionManager();
connectionManager.setDefaultMaxPerRoute(getSolrMaxConnectionsPerRoute(indexConnectionParams));
connectionManager.setMaxTotal(getSolrMaxConnectionsTotal(indexConnectionParams));
HttpClient httpClient = new DefaultHttpClient(connectionManager);
return new HashSet(createHttpSolrClients(indexConnectionParams, httpClient));
} else {
throw new RuntimeException("Only 'cloud' and 'classic' are valid values for solr.mode, but got " + solrMode);
}
}

代码示例来源：origin: kite-sdk/kite

DocumentLoader getLoader(RetryPolicyFactory retryPolicyFactory, MetricsFacade retryMetricsFacade) {
if (context instanceof SolrMorphlineContext) {
DocumentLoader loader = ((SolrMorphlineContext)context).getDocumentLoader();
if (loader != null) {
return loader;
}
}

SolrClient solrServer = getSolrServer();
if (solrServer instanceof CloudSolrClient) {
try {
((CloudSolrClient)solrServer).setIdField(getIndexSchema().getUniqueKeyField().getName());
} catch (RuntimeException e) {
try {
solrServer.close(); // release resources
} catch (Exception ex2) {
LOG.debug("Cannot get index schema and cannot shutdown CloudSolrServer", ex2);
}
throw new RuntimeException(e); // rethrow root cause
}
}
if (retryPolicyFactory != null) {
solrServer = new RetryingSolrServer(solrServer, retryPolicyFactory, retryMetricsFacade);
}

return new SolrServerDocumentLoader(solrServer, batchSize);
}

代码示例来源：origin: apache/jackrabbit-oak

cloudSolrServer.setZkConnectTimeout(remoteSolrServerConfiguration.getConnectionTimeout());
cloudSolrServer.setZkClientTimeout(remoteSolrServerConfiguration.getSocketTimeout());
cloudSolrServer.setIdField(OakSolrConfigurationDefaults.PATH_FIELD_NAME);

代码示例来源：origin: org.apache.jackrabbit/oak-solr-core

cloudSolrServer.setZkConnectTimeout(remoteSolrServerConfiguration.getConnectionTimeout());
cloudSolrServer.setZkClientTimeout(remoteSolrServerConfiguration.getSocketTimeout());
cloudSolrServer.setIdField(OakSolrConfigurationDefaults.PATH_FIELD_NAME);

代码示例来源：origin: com.ngdata/hbase-indexer-mr

solrServer.setZkConnectTimeout(zkSessionTimeout);
solrServer.setDefaultCollection(hbaseIndexingOpts.collection);
solrServer.setIdField(uniqueKeyField);