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

ZkStateReader.<init>介绍

暂无

代码示例

代码示例来源：origin: com.cloudera.search/search-mr

public DocCollection extractDocCollection(String zkHost, String collection) {
 if (collection == null) {
  throw new IllegalArgumentException("collection must not be null");
 }
 SolrZkClient zkClient = getZkClient(zkHost);
 
 try (ZkStateReader zkStateReader = new ZkStateReader(zkClient)) {
  try {
   // first check for alias
   collection = checkForAlias(zkClient, collection);
   zkStateReader.createClusterStateWatchersAndUpdate();
  } catch (Exception e) {
   throw new IllegalArgumentException("Cannot find expected information for SolrCloud in ZooKeeper: " + zkHost, e);
  }
  
  try {
   return zkStateReader.getClusterState().getCollection(collection);
  } catch (SolrException e) {
   throw new IllegalArgumentException("Cannot find collection '" + collection + "' in ZooKeeper: " + zkHost, e);
  }
 } finally {
  zkClient.close();
 }    
}

代码示例来源：origin: cloudera/search

public DocCollection extractDocCollection(String zkHost, String collection) {
 if (collection == null) {
  throw new IllegalArgumentException("collection must not be null");
 }
 SolrZkClient zkClient = getZkClient(zkHost);
 
 try {
  ZkStateReader zkStateReader = new ZkStateReader(zkClient);
  try {
   // first check for alias
   collection = checkForAlias(zkClient, collection);
   zkStateReader.createClusterStateWatchersAndUpdate();
  } catch (Exception e) {
   throw new IllegalArgumentException("Cannot find expected information for SolrCloud in ZooKeeper: " + zkHost, e);
  }
  
  try {
   return zkStateReader.getClusterState().getCollection(collection);
  } catch (SolrException e) {
   throw new IllegalArgumentException("Cannot find collection '" + collection + "' in ZooKeeper: " + zkHost, e);
  }
 } finally {
  zkClient.close();
 }    
}

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

@Override
public void connect() {
 if (zkStateReader == null) {
  synchronized (this) {
   if (zkStateReader == null) {
    ZkStateReader zk = null;
    try {
     zk = new ZkStateReader(zkHost, zkClientTimeout, zkConnectTimeout);
     zk.createClusterStateWatchersAndUpdate();
     zkStateReader = zk;
     log.info("Cluster at {} ready", zkHost);
    } catch (InterruptedException e) {
     zk.close();
     Thread.currentThread().interrupt();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (KeeperException e) {
     zk.close();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (Exception e) {
     if (zk != null) zk.close();
     // do not wrap because clients may be relying on the underlying exception being thrown
     throw e;
    }
   }
  }
 }
}

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

/**
 * Connect to the zookeeper ensemble.
 * This is an optional method that may be used to force a connect before any other requests are sent.
 *
 */
public void connect() {
 if (zkStateReader == null) {
  synchronized (this) {
   if (zkStateReader == null) {
    ZkStateReader zk = null;
    try {
     zk = new ZkStateReader(zkHost, zkClientTimeout, zkConnectTimeout);
     zk.createClusterStateWatchersAndUpdate();
     zkStateReader = zk;
    } catch (InterruptedException e) {
     zk.close();
     Thread.currentThread().interrupt();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (KeeperException e) {
     zk.close();
     throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "", e);
    } catch (Exception e) {
     if (zk != null) zk.close();
     // do not wrap because clients may be relying on the underlying exception being thrown
     throw e;
    }
   }
  }
 }
}

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

/** Delete all collections (and aliases) */
public void deleteAllCollections() throws Exception {
 try (ZkStateReader reader = new ZkStateReader(solrClient.getZkStateReader().getZkClient())) {
  reader.createClusterStateWatchersAndUpdate(); // up to date aliases & collections
  reader.aliasesManager.applyModificationAndExportToZk(aliases -> Aliases.EMPTY);
  for (String collection : reader.getClusterState().getCollectionStates().keySet()) {
   CollectionAdminRequest.deleteCollection(collection).process(solrClient);
  }
 }
}

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

@Override
public void distribSetUp() throws Exception {
 super.distribSetUp();
 // ignoreException(".*");
 if (sliceCount > 0) {
  System.setProperty("numShards", Integer.toString(sliceCount));
 } else {
  System.clearProperty("numShards");
 }
 if (isSSLMode()) {
  System.clearProperty("urlScheme");
  try (ZkStateReader zkStateReader = new ZkStateReader(zkServer.getZkAddress(),
    AbstractZkTestCase.TIMEOUT, AbstractZkTestCase.TIMEOUT)) {
   try {
    zkStateReader.getZkClient().create(ZkStateReader.CLUSTER_PROPS,
      Utils.toJSON(Collections.singletonMap("urlScheme", "https")),
      CreateMode.PERSISTENT, true);
   } catch (KeeperException.NodeExistsException e) {
    ZkNodeProps props = ZkNodeProps.load(zkStateReader.getZkClient().getData(ZkStateReader.CLUSTER_PROPS,
      null, null, true));
    zkStateReader.getZkClient().setData(ZkStateReader.CLUSTER_PROPS, Utils.toJSON(props.plus("urlScheme", "https")), true);
   }
  }
 }
 if (useTlogReplicas()) {
  log.info("Will use {} replicas unless explicitly asked otherwise", Replica.Type.TLOG);
 } else {
  log.info("Will use {} replicas unless explicitly asked otherwise", Replica.Type.NRT);
 }
}

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

try (ZkStateReader zk = new ZkStateReader(zkServer.getZkAddress(), AbstractZkTestCase.TIMEOUT,
  AbstractZkTestCase.TIMEOUT)) {
 zk.createClusterStateWatchersAndUpdate();