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

ZkStateReader.getLeader介绍

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

代码示例

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

/**
 * Get shard leader properties, with retry if none exist.
 */
public Replica getLeaderRetry(String collection, String shard, int timeout) throws InterruptedException {
 long timeoutAt = System.nanoTime() + TimeUnit.NANOSECONDS.convert(timeout, TimeUnit.MILLISECONDS);
 while (true) {
  Replica leader = getLeader(collection, shard);
  if (leader != null) return leader;
  if (System.nanoTime() >= timeoutAt || closed) break;
  Thread.sleep(GET_LEADER_RETRY_INTERVAL_MS);
 }
 throw new SolrException(ErrorCode.SERVICE_UNAVAILABLE, "No registered leader was found after waiting for "
   + timeout + "ms " + ", collection: " + collection + " slice: " + shard);
}

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

/**
 * Get shard leader properties, with retry if none exist.
 */
public Replica getLeaderRetry(String collection, String shard, int timeout) throws InterruptedException {
 long timeoutAt = System.nanoTime() + TimeUnit.NANOSECONDS.convert(timeout, TimeUnit.MILLISECONDS);
 while (true) {
  Replica leader = getLeader(collection, shard);
  if (leader != null) return leader;
  if (System.nanoTime() >= timeoutAt || closed) break;
  Thread.sleep(GET_LEADER_RETRY_INTERVAL_MS);
 }
 throw new SolrException(ErrorCode.SERVICE_UNAVAILABLE, "No registered leader was found after waiting for "
   + timeout + "ms " + ", collection: " + collection + " slice: " + shard + " saw state=" + clusterState.getCollectionOrNull(collection)
   + " with live_nodes=" + clusterState.getLiveNodes());
}