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

ClusterState.getRoutingTable介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String id, String routing) {
  int shardId = generateShardId(indexMetaData(clusterState, index), id, routing);
  return clusterState.getRoutingTable().shardRoutingTable(index, shardId);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

Set<ShardRouting> seenShardRoutings = new HashSet<>(); // to prevent duplicates
for (StartedShardEntry task : tasks) {
  ShardRouting matched = currentState.getRoutingTable().getByAllocationId(task.shardId, task.allocationId);
  if (matched == null) {

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * @return all shard ids the request should run on
 */
protected List<ShardId> shards(Request request, ClusterState clusterState) {
  List<ShardId> shardIds = new ArrayList<>();
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
  for (String index : concreteIndices) {
    IndexMetaData indexMetaData = clusterState.metaData().getIndices().get(index);
    if (indexMetaData != null) {
      for (IntObjectCursor<IndexShardRoutingTable> shardRouting
          : clusterState.getRoutingTable().indicesRouting().get(index).getShards()) {
        shardIds.add(shardRouting.value.shardId());
      }
    }
  }
  return shardIds;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) {
  final IndexShardRoutingTable indexShard = clusterState.getRoutingTable().shardRoutingTable(index, shardId);
  return preferenceActiveShardIterator(indexShard, clusterState.nodes().getLocalNodeId(), clusterState.nodes(),
    preference, null, null);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

ShardRouting matched = currentState.getRoutingTable().getByAllocationId(task.shardId, task.allocationId);
if (matched == null) {
  Set<String> inSyncAllocationIds = indexMetaData.inSyncAllocationIds(task.shardId.id());

代码示例来源：origin: org.elasticsearch/elasticsearch

this.activeShardsPercent = 100;
} else {
  List<ShardRouting> shardRoutings = clusterState.getRoutingTable().allShards();
  int activeShardCount = 0;
  int totalShardCount = 0;

代码示例来源：origin: org.elasticsearch/elasticsearch

private boolean waitingShardsStartedOrUnassigned(ClusterChangedEvent event) {
  SnapshotsInProgress curr = event.state().custom(SnapshotsInProgress.TYPE);
  if (curr != null) {
    for (SnapshotsInProgress.Entry entry : curr.entries()) {
      if (entry.state() == State.STARTED && !entry.waitingIndices().isEmpty()) {
        for (ObjectCursor<String> index : entry.waitingIndices().keys()) {
          if (event.indexRoutingTableChanged(index.value)) {
            IndexRoutingTable indexShardRoutingTable = event.state().getRoutingTable().index(index.value);
            for (ShardId shardId : entry.waitingIndices().get(index.value)) {
              ShardRouting shardRouting = indexShardRoutingTable.shard(shardId.id()).primaryShard();
              if (shardRouting != null && (shardRouting.started() || shardRouting.unassigned())) {
                return true;
              }
            }
          }
        }
      }
    }
  }
  return false;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

protected List<ShardRouting> getShards(ShardId shardId, ClusterState state) {
  // can be null if the index is deleted / closed on us..
  final IndexShardRoutingTable shardRoutingTable = state.getRoutingTable().shardRoutingTableOrNull(shardId);
  List<ShardRouting> shards = shardRoutingTable == null ? Collections.emptyList() : shardRoutingTable.shards();
  return shards;
}

代码示例来源：origin: harbby/presto-connectors

protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String type, String id, String routing) {
  int shardId = generateShardId(clusterState, index, type, id, routing);
  return clusterState.getRoutingTable().shardRoutingTable(index, shardId);
}

代码示例来源：origin: com.scireum/sirius-search

private Map<Integer, List<ShardRouting>> getShardRoutings(ClusterStateResponse clusterStateResponse,
                               Map.Entry<String, ClusterIndexHealth> index) {
    Map<Integer, List<ShardRouting>> shardRoutings = new HashMap<>();
    for (Map.Entry<Integer, ClusterShardHealth> shard : index.getValue().getShards().entrySet()) {

      List<ShardRouting> shardRoutingList = clusterStateResponse.getState()
                                   .getRoutingTable()
                                   .index(index.getValue().getIndex())
                                   .getShards()
                                   .get(shard.getKey())
                                   .getShards();
      shardRoutings.put(shard.getKey(), shardRoutingList);
    }
    return shardRoutings;
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String id, String routing) {
  int shardId = generateShardId(indexMetaData(clusterState, index), id, routing);
  return clusterState.getRoutingTable().shardRoutingTable(index, shardId);
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String id, String routing) {
  int shardId = generateShardId(indexMetaData(clusterState, index), id, routing);
  return clusterState.getRoutingTable().shardRoutingTable(index, shardId);
}

代码示例来源：origin: apache/servicemix-bundles

protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String id, String routing) {
  int shardId = generateShardId(indexMetaData(clusterState, index), id, routing);
  return clusterState.getRoutingTable().shardRoutingTable(index, shardId);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

IndexRoutingTable indexRoutingTable = clusterState.getRoutingTable().index(indexName);
for (int i = 0; i < indexMetaData.getNumberOfShards(); i++) {
  ShardId shardId = new ShardId(indexMetaData.getIndex(), i);

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

/**
 * @return all shard ids the request should run on
 */
protected List<ShardId> shards(Request request, ClusterState clusterState) {
  List<ShardId> shardIds = new ArrayList<>();
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
  for (String index : concreteIndices) {
    IndexMetaData indexMetaData = clusterState.metaData().getIndices().get(index);
    if (indexMetaData != null) {
      for (IntObjectCursor<IndexShardRoutingTable> shardRouting : clusterState.getRoutingTable().indicesRouting().get(index).getShards()) {
        shardIds.add(shardRouting.value.shardId());
      }
    }
  }
  return shardIds;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * @return all shard ids the request should run on
 */
protected List<ShardId> shards(Request request, ClusterState clusterState) {
  List<ShardId> shardIds = new ArrayList<>();
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
  for (String index : concreteIndices) {
    IndexMetaData indexMetaData = clusterState.metaData().getIndices().get(index);
    if (indexMetaData != null) {
      for (IntObjectCursor<IndexShardRoutingTable> shardRouting : clusterState.getRoutingTable().indicesRouting().get(index).getShards()) {
        shardIds.add(shardRouting.value.shardId());
      }
    }
  }
  return shardIds;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) {
  final IndexShardRoutingTable indexShard = clusterState.getRoutingTable().shardRoutingTable(index, shardId);
  return preferenceActiveShardIterator(indexShard, clusterState.nodes().getLocalNodeId(), clusterState.nodes(), preference);
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) {
  final IndexShardRoutingTable indexShard = clusterState.getRoutingTable().shardRoutingTable(index, shardId);
  return preferenceActiveShardIterator(indexShard, clusterState.nodes().getLocalNodeId(), clusterState.nodes(), preference, null, null);
}

代码示例来源：origin: apache/servicemix-bundles

public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) {
  final IndexShardRoutingTable indexShard = clusterState.getRoutingTable().shardRoutingTable(index, shardId);
  return preferenceActiveShardIterator(indexShard, clusterState.nodes().getLocalNodeId(), clusterState.nodes(), preference, null, null);
}

代码示例来源：origin: harbby/presto-connectors

public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) {
  final IndexShardRoutingTable indexShard = clusterState.getRoutingTable().shardRoutingTable(index, shardId);
  return preferenceActiveShardIterator(indexShard, clusterState.nodes().localNodeId(), clusterState.nodes(), preference);
}