本文整理了Java中org.elasticsearch.cluster.node.DiscoveryNodes.smallestNonClientNodeVersion()
方法的一些代码示例,展示了DiscoveryNodes.smallestNonClientNodeVersion()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DiscoveryNodes.smallestNonClientNodeVersion()
方法的具体详情如下:
包路径:org.elasticsearch.cluster.node.DiscoveryNodes
类名称:DiscoveryNodes
方法名:smallestNonClientNodeVersion
[英]Returns the version of the node with the oldest version in the cluster that is not a client node
[中]返回具有群集中非客户端节点的最旧版本的节点的版本
代码示例来源:origin: org.elasticsearch.module/reindex
@Override
protected void doExecute(Task task, UpdateByQueryRequest request,
ActionListener<BulkIndexByScrollResponse> listener) {
new AsyncIndexBySearchAction((BulkByScrollTask) task, logger, scriptService, client, threadPool,
clusterService.state().nodes().smallestNonClientNodeVersion(), request, listener).start();
}
代码示例来源:origin: com.strapdata.elasticsearch.module/reindex
@Override
protected void doExecute(Task task, UpdateByQueryRequest request,
ActionListener<BulkIndexByScrollResponse> listener) {
new AsyncIndexBySearchAction((BulkByScrollTask) task, logger, scriptService, client, threadPool,
clusterService.state().nodes().smallestNonClientNodeVersion(), request, listener).start();
}
代码示例来源:origin: org.elasticsearch.module/reindex
@Override
protected void doExecute(Task task, ReindexRequest request, ActionListener<ReindexResponse> listener) {
validateAgainstAliases(request.getSearchRequest(), request.getDestination(), indexNameExpressionResolver, autoCreateIndex,
clusterService.state());
new AsyncIndexBySearchAction((BulkByScrollTask) task, logger, scriptService, client, threadPool,
clusterService.state().nodes().smallestNonClientNodeVersion(), request, listener).start();
}
代码示例来源:origin: com.strapdata.elasticsearch.module/reindex
@Override
protected void doExecute(Task task, ReindexRequest request, ActionListener<ReindexResponse> listener) {
validateAgainstAliases(request.getSearchRequest(), request.getDestination(), indexNameExpressionResolver, autoCreateIndex,
clusterService.state());
new AsyncIndexBySearchAction((BulkByScrollTask) task, logger, scriptService, client, threadPool,
clusterService.state().nodes().smallestNonClientNodeVersion(), request, listener).start();
}
代码示例来源:origin: harbby/presto-connectors
final Version createdVersion = Version.smallest(version, nodes.smallestNonClientNodeVersion());
indexSettingsBuilder.put(SETTING_VERSION_CREATED, createdVersion);
内容来源于网络,如有侵权,请联系作者删除!