本文整理了Java中org.elasticsearch.cluster.metadata.MetaData.resolveSearchRouting()
方法的一些代码示例,展示了MetaData.resolveSearchRouting()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetaData.resolveSearchRouting()
方法的具体详情如下:
包路径:org.elasticsearch.cluster.metadata.MetaData
类名称: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!