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

ZkStateReader.updateWatchedCollection介绍

暂无

代码示例

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

if (updateWatchedCollection(collection, newState)) {
 constructState(Collections.singleton(collection));

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

updateWatchedCollection(collection);

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

DocCollection live = getCollectionLive(this, s);
if (live != null) {
 updateWatchedCollection(live);

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

public Integer compareStateVersions(String coll, int version) {
 DocCollection collection = clusterState.getCollectionOrNull(coll);
 if (collection == null) return null;
 if (collection.getZNodeVersion() < version) {
  log.debug("server older than client {}<{}", collection.getZNodeVersion(), version);
  DocCollection nu = getCollectionLive(this, coll);
  if (nu == null) return -1 ;
  if (nu.getZNodeVersion() > collection.getZNodeVersion()) {
   updateWatchedCollection(nu);
   collection = nu;
  }
 }
 
 if (collection.getZNodeVersion() == version) {
  return null;
 }
 
 log.debug("wrong version from client {}!={} ", version, collection.getZNodeVersion());
 
 return collection.getZNodeVersion();
}

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

public Integer compareStateVersions(String coll, int version) {
 DocCollection collection = clusterState.getCollectionOrNull(coll);
 if (collection == null) return null;
 if (collection.getZNodeVersion() < version) {
  log.debug("Server older than client {}<{}", collection.getZNodeVersion(), version);
  DocCollection nu = getCollectionLive(this, coll);
  if (nu == null) return -1 ;
  if (nu.getZNodeVersion() > collection.getZNodeVersion()) {
   if (updateWatchedCollection(coll, nu)) {
    synchronized (getUpdateLock()) {
     constructState(Collections.singleton(coll));
    }
   }
   collection = nu;
  }
 }
 
 if (collection.getZNodeVersion() == version) {
  return null;
 }
 
 log.debug("Wrong version from client [{}]!=[{}]", version, collection.getZNodeVersion());
 
 return collection.getZNodeVersion();
}