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

ZkStateReader.createClusterStateWatchersAndUpdate介绍

暂无

代码示例

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

@Override
 public void command() {
  try {
   ZkStateReader.this.createClusterStateWatchersAndUpdate();
  } catch (KeeperException e) {
   log.error("A ZK error has occurred", e);
   throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "A ZK error has occurred", e);
  } catch (InterruptedException e) {
   // Restore the interrupted status
   Thread.currentThread().interrupt();
   log.error("Interrupted", e);
   throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR, "Interrupted", e);
  }
 }
});

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

@Override
 public void command() {
  try {
   ZkStateReader.this.createClusterStateWatchersAndUpdate();
  } catch (KeeperException e) {
   log.error("", e);
   throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR,
     "", e);
  } catch (InterruptedException e) {
   // Restore the interrupted status
   Thread.currentThread().interrupt();
   log.error("", e);
   throw new ZooKeeperException(SolrException.ErrorCode.SERVER_ERROR,
     "", e);
  }
 }
});

代码示例来源：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: 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: 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

/**
 * Forcibly refresh cluster state from ZK. Do this only to avoid race conditions because it's expensive.
 *
 * It is cheaper to call {@link #forceUpdateCollection(String)} on a single collection if you must.
 * 
 * @lucene.internal
 */
public void forciblyRefreshAllClusterStateSlow() throws KeeperException, InterruptedException {
 synchronized (getUpdateLock()) {
  if (clusterState == null) {
   // Never initialized, just run normal initialization.
   createClusterStateWatchersAndUpdate();
   return;
  }
  // No need to set watchers because we should already have watchers registered for everything.
  refreshCollectionList(null);
  refreshLiveNodes(null);
  refreshLegacyClusterState(null);
  // Need a copy so we don't delete from what we're iterating over.
  Collection<String> safeCopy = new ArrayList<>(watchedCollectionStates.keySet());
  Set<String> updatedCollections = new HashSet<>();
  for (String coll : safeCopy) {
   DocCollection newState = fetchCollectionState(coll, null);
   if (updateWatchedCollection(coll, newState)) {
    updatedCollections.add(coll);
   }
  }
  constructState(updatedCollections);
 }
}

代码示例来源：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

try (ZkStateReader zk = new ZkStateReader(zkServer.getZkAddress(), AbstractZkTestCase.TIMEOUT,
  AbstractZkTestCase.TIMEOUT)) {
 zk.createClusterStateWatchersAndUpdate();
 clusterState = zk.getClusterState();
 final DocCollection docCollection = clusterState.getCollectionOrNull(DEFAULT_COLLECTION);