org.elasticsearch.cluster.metadata.MetaData.resolveWriteIndexRouting()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(87)

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

MetaData.resolveWriteIndexRouting介绍

[英]Returns indexing routing for the given aliasOrIndex. Resolves routing from the alias metadata used in the write index.
[中]返回给定[$0$]的索引路由。从写入索引中使用的别名元数据解析路由。

代码示例

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

public void resolveRouting(MetaData metaData) {
  routing(metaData.resolveWriteIndexRouting(parent, routing, index));
}

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

public static void resolveAndValidateRouting(MetaData metaData, String concreteIndex, UpdateRequest request) {
  request.routing((metaData.resolveWriteIndexRouting(request.parent(), request.routing(), request.index())));
  // Fail fast on the node that received the request, rather than failing when translating on the index or delete request.
  if (request.routing() == null && metaData.routingRequired(concreteIndex, request.type())) {
    throw new RoutingMissingException(concreteIndex, request.type(), request.id());
  }
}

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

break;
case DELETE:
  docWriteRequest.routing(metaData.resolveWriteIndexRouting(docWriteRequest.parent(), docWriteRequest.routing(),
    docWriteRequest.index()));

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

public void resolveRouting(MetaData metaData) {
  routing(metaData.resolveWriteIndexRouting(parent, routing, index));
}

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

public void resolveRouting(MetaData metaData) {
  routing(metaData.resolveWriteIndexRouting(parent, routing, index));
}

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

public static void resolveAndValidateRouting(MetaData metaData, String concreteIndex, UpdateRequest request) {
  request.routing((metaData.resolveWriteIndexRouting(request.parent(), request.routing(), request.index())));
  // Fail fast on the node that received the request, rather than failing when translating on the index or delete request.
  if (request.routing() == null && metaData.routingRequired(concreteIndex, request.type())) {
    throw new RoutingMissingException(concreteIndex, request.type(), request.id());
  }
}

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

public static void resolveAndValidateRouting(MetaData metaData, String concreteIndex, UpdateRequest request) {
  request.routing((metaData.resolveWriteIndexRouting(request.parent(), request.routing(), request.index())));
  // Fail fast on the node that received the request, rather than failing when translating on the index or delete request.
  if (request.routing() == null && metaData.routingRequired(concreteIndex, request.type())) {
    throw new RoutingMissingException(concreteIndex, request.type(), request.id());
  }
}

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

break;
case DELETE:
  docWriteRequest.routing(metaData.resolveWriteIndexRouting(docWriteRequest.parent(), docWriteRequest.routing(), docWriteRequest.index()));

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

break;
case DELETE:
  docWriteRequest.routing(metaData.resolveWriteIndexRouting(docWriteRequest.parent(), docWriteRequest.routing(), docWriteRequest.index()));

相关文章