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

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

CloudSolrClient.close介绍

暂无

代码示例

代码示例来源：origin: org.apache.solr/solr-solrj

public void close() throws IOException {
if(cache == null) {
cloudSolrClient.close();
}
}

代码示例来源：origin: org.apache.solr/solr-solrj

public void close() throws IOException {
if(cache == null) {
cloudSolrClient.close();
}
}

代码示例来源：origin: org.apache.solr/solr-solrj

public void close() throws IOException {
if(cache == null) {
if (cloudSolrClient != null) {
cloudSolrClient.close();
}
}
}

代码示例来源：origin: org.apache.solr/solr-solrj

@Override
public void close() throws IOException {
if(cache == null && cloudSolrClient != null) {
cloudSolrClient.close();
}
tupleSource.close();
}

代码示例来源：origin: com.hynnet/solr-solrj

/**
* Closes the CloudSolrStream
**/
public void close() throws IOException {
for(TupleStream solrStream : solrStreams) {
solrStream.close();
}
if(cache == null) {
cloudSolrClient.close();
}
}

代码示例来源：origin: org.apache.solr/solr-test-framework

@Override
public void distribTearDown() throws Exception {
if (VERBOSE || printLayoutOnTearDown) {
super.printLayout();
}
closeRestTestHarnesses(); // TODO: close here or later?
if (commonCloudSolrClient != null) {
commonCloudSolrClient.close();
}
if (controlClient != null) {
controlClient.close();
}
if (cloudClient != null) {
cloudClient.close();
}
if (controlClientCloud != null) {
controlClientCloud.close();
}
super.distribTearDown();
System.clearProperty("zkHost");
System.clearProperty("numShards");
// close socket proxies after super.distribTearDown
if (!proxies.isEmpty()) {
for (SocketProxy proxy : proxies.values()) {
proxy.close();
}
}
}

代码示例来源：origin: stackoverflow.com

if (client != null) {
try {
client.close();
} catch (IOException e) {
throw new RuntimeException(

代码示例来源：origin: org.apache.solr/solr-solrj

public void close() throws IOException {
try {
if (initialRun || runCount > 0) {
persistCheckpoints();
initialRun = false;
runCount = 0;
}
} finally {
if(solrStreams != null) {
for (TupleStream solrStream : solrStreams) {
solrStream.close();
}
}
if (streamContext != null && streamContext.getSolrClientCache() == null) {
cloudSolrClient.close();
}
}
}

代码示例来源：origin: NGDATA/hbase-indexer

server.setDefaultCollection(options.collection);
server.commit();
server.close();
} else {
for (List urls : options.shardUrls) {

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

return cloudSolrServer;
} else {
cloudSolrServer.close();
throw new IOException("the found SolrCloud server is not alive");
cloudSolrServer.close();
throw new IOException("the found SolrCloud server is not alive");
} else {
cloudSolrServer.close();
throw new IOException("could not connect to Zookeeper hosted at " + remoteSolrServerConfiguration.getSolrZkHost());

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

return cloudSolrServer;
} else {
cloudSolrServer.close();
throw new IOException("the found SolrCloud server is not alive");
cloudSolrServer.close();
throw new IOException("the found SolrCloud server is not alive");
} else {
cloudSolrServer.close();
throw new IOException("could not connect to Zookeeper hosted at " + remoteSolrServerConfiguration.getSolrZkHost());

代码示例来源：origin: stackoverflow.com

final CloudSolrClient server = new CloudSolrClient("localhost:2181");
try {
//probably this is the line that missed from your code...
server.connect();
final ClusterState clusterState = server.getZkStateReader().getClusterState();
final DocCollection collection = clusterState.getCollection("collection1");
//EVRIKA! collection object
// and get the leader of the collection...pretty easy.
Replica leader = clusterState.getLeader("collection1", "shard1");
} catch (Exception e) {
// do your stuff
} finally {
server.close();
}