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

ZkStateReader.getLeaderRetry介绍

[英]Get shard leader properties, with retry if none exist.
[中]获取碎片引线属性，如果不存在，请重试。

代码示例

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

/**
 * Get shard leader properties, with retry if none exist.
 */
public Replica getLeaderRetry(String collection, String shard) throws InterruptedException {
 return getLeaderRetry(collection, shard, GET_LEADER_RETRY_DEFAULT_TIMEOUT);
}

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

/**
 * Get shard leader properties, with retry if none exist.
 */
public Replica getLeaderRetry(String collection, String shard) throws InterruptedException {
 return getLeaderRetry(collection, shard, GET_LEADER_RETRY_DEFAULT_TIMEOUT);
}

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

public String getLeaderUrl(String collection, String shard, int timeout) throws InterruptedException {
 ZkCoreNodeProps props = new ZkCoreNodeProps(getLeaderRetry(collection, shard, timeout));
 return props.getCoreUrl();
}

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

public String getLeaderUrl(String collection, String shard, int timeout)
  throws InterruptedException, KeeperException {
 ZkCoreNodeProps props = new ZkCoreNodeProps(getLeaderRetry(collection,
   shard, timeout));
 return props.getCoreUrl();
}

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

protected Replica getShardLeader(String testCollectionName, String shardId, int timeoutSecs) throws Exception {
 Replica leader = null;
 long timeout = System.nanoTime() + TimeUnit.NANOSECONDS.convert(timeoutSecs, TimeUnit.SECONDS);
 while (System.nanoTime() < timeout) {
  Replica tmp = null;
  try {
   tmp = cloudClient.getZkStateReader().getLeaderRetry(testCollectionName, shardId);
  } catch (Exception exc) {}
  if (tmp != null && "active".equals(tmp.getStr(ZkStateReader.STATE_PROP))) {
   leader = tmp;
   break;
  }
  Thread.sleep(1000);
 }
 assertNotNull("Could not find active leader for " + shardId + " of " +
   testCollectionName + " after "+timeoutSecs+" secs; clusterState: " +
   printClusterStateInfo(testCollectionName), leader);
 return leader;
}

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

ZkStateReader zkStateReader = jettys.get(0).getCoreContainer().getZkController()
  .getZkStateReader();
zkStateReader.getLeaderRetry("collection1", "shard" + (i + 2), 15000);

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

leader = zkStateReader.getLeaderRetry(collection, slice);
} catch (Throwable t) {
 log.error("Could not get leader", t);

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

zkStateReader.getLeaderRetry(DEFAULT_COLLECTION, "shard" + i, 10000);

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

Replica leader = zkStateReader.getLeaderRetry(collectionName, s.getName(), (int)timeout.timeLeft(TimeUnit.MILLISECONDS));
long leaderIndexVersion = -1;
while (!timeout.hasTimedOut()) {