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

MetaData.resolveSearchRouting介绍

暂无

代码示例

代码示例来源：origin: meltwater/elasticsearch-batch-percolator

@Override
protected GroupShardsIterator shards(ClusterState clusterState, BatchPercolateRequest request, String[] concreteIndices) {
  Map<String, Set<String>> routingMap = clusterState.metaData().resolveSearchRouting(null, request.indices());
  return clusterService.operationRouting().searchShards(clusterState, request.indices(), concreteIndices, routingMap, null);
}

代码示例来源：origin: crate/elasticsearch-inout-plugin

@Override
protected GroupShardsIterator shards(ClusterState clusterState, ExportRequest request, String[] concreteIndices) {
  Map<String, Set<String>> routingMap = clusterState.metaData().resolveSearchRouting(request.routing(), request.indices());
  return clusterService.operationRouting().searchShards(clusterState, request.indices(), concreteIndices, routingMap, request.preference());
}

代码示例来源：origin: crate/elasticsearch-inout-plugin

@Override
protected GroupShardsIterator shards(ClusterState clusterState,
    SearchIntoRequest request, String[] concreteIndices) {
  Map<String, Set<String>> routingMap = clusterState.metaData()
      .resolveSearchRouting(request.routing(), request.indices());
  return clusterService.operationRouting().searchShards(clusterState,
      request.indices(), concreteIndices, routingMap,
      request.preference());
}

代码示例来源：origin: yakaz/elasticsearch-action-updatebyquery

protected void doExecute(UpdateByQueryRequest request, ActionListener<UpdateByQueryResponse> listener) {
  request.nowInMillis = System.currentTimeMillis();
  MetaData metaData = clusterService.state().metaData();
  String[] concreteIndices = metaData.concreteIndices(IndicesOptions.lenientExpandOpen(), request.indices());
  Map<String, Set<String>> routingMap = metaData.resolveSearchRouting(request.routing(), request.indices());
  if (concreteIndices.length == 1) {
    doExecuteIndexRequest(request, metaData, concreteIndices[0], routingMap, new SingleIndexUpdateByQueryActionListener(request.nowInMillis, listener));
  } else {
    MultipleIndexUpdateByQueryActionListener indexActionListener =
        new MultipleIndexUpdateByQueryActionListener(request.nowInMillis, listener, concreteIndices.length);
    for (String concreteIndex : concreteIndices) {
      doExecuteIndexRequest(request, metaData, concreteIndex, routingMap, indexActionListener);
    }
  }
}