gpt4 book ai didi

org.apache.solr.common.cloud.ZkStateReader.getLeader()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-15 11:08:40 25 4
gpt4 key购买 nike

本文整理了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());
}

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com