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

MetaData.resolveIndexRouting介绍

[英]Returns indexing routing for the given index.
[中]返回给定索引的索引路由。

代码示例

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

concreteSingleIndex = indexNameExpressionResolver.concreteSingleIndex(clusterState, item).getName();
item.routing(clusterState.metaData().resolveIndexRouting(item.parent(), item.routing(), item.index()));
if ((item.routing() == null) && (clusterState.getMetaData().routingRequired(concreteSingleIndex, item.type()))) {
  responses.set(i, newItemFailure(concreteSingleIndex, item.type(), item.id(),

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

TermVectorsRequest termVectorsRequest = request.requests.get(i);
termVectorsRequest.routing(clusterState.metaData()
  .resolveIndexRouting(termVectorsRequest.parent(), termVectorsRequest.routing(), termVectorsRequest.index()));
if (!clusterState.metaData().hasConcreteIndex(termVectorsRequest.index())) {
  responses.set(i, new MultiTermVectorsItemResponse(null,

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  // update the routing (request#index here is possibly an alias or a parent)
  request.request().routing(state.metaData()
    .resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

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

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  IndexMetaData indexMeta = state.getMetaData().index(request.concreteIndex());
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(),
    request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

public static void resolveAndValidateRouting(MetaData metaData, String concreteIndex, UpdateRequest request) {
  request.routing((metaData.resolveIndexRouting(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: com.strapdata.elasticsearch/elasticsearch

public static void resolveAndValidateRouting(MetaData metaData, String concreteIndex, UpdateRequest request) {
  request.routing((metaData.resolveIndexRouting(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: harbby/presto-connectors

public static void resolveAndValidateRouting(final MetaData metaData, String concreteIndex, DeleteRequest request) {
  request.routing(metaData.resolveIndexRouting(request.routing(), request.index()));
  if (metaData.hasIndex(concreteIndex)) {
    // check if routing is required, if so, throw error if routing wasn't specified
    MappingMetaData mappingMd = metaData.index(concreteIndex).mappingOrDefault(request.type());
    if (mappingMd != null && mappingMd.routing().required()) {
      if (request.routing() == null) {
        if (request.versionType() != VersionType.INTERNAL) {
          // TODO: implement this feature
          throw new IllegalArgumentException("routing value is required for deleting documents of type [" + request.type()
            + "] while using version_type [" + request.versionType() + "]");
        }
        throw new RoutingMissingException(concreteIndex, request.type(), request.id());
      }
    }
  }
}

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

TermVectorsRequest termVectorsRequest = request.requests.get(i);
termVectorsRequest.startTime = System.currentTimeMillis();
termVectorsRequest.routing(clusterState.metaData().resolveIndexRouting(termVectorsRequest.routing(), termVectorsRequest.index()));
if (!clusterState.metaData().hasConcreteIndex(termVectorsRequest.index())) {
  responses.set(i, new MultiTermVectorsItemResponse(null, new MultiTermVectorsResponse.Failure(termVectorsRequest.index(),

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

concreteSingleIndex = indexNameExpressionResolver.concreteSingleIndex(clusterState, item).getName();
item.routing(clusterState.metaData().resolveIndexRouting(item.parent(), item.routing(), item.index()));
if ((item.routing() == null) && (clusterState.getMetaData().routingRequired(concreteSingleIndex, item.type()))) {
  responses.set(i, newItemFailure(concreteSingleIndex, item.type(), item.id(),

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

for (int i = 0; i < request.requests.size(); i++) {
  TermVectorsRequest termVectorsRequest = request.requests.get(i);
  termVectorsRequest.routing(clusterState.metaData().resolveIndexRouting(termVectorsRequest.parent(), termVectorsRequest.routing(), termVectorsRequest.index()));
  if (!clusterState.metaData().hasConcreteIndex(termVectorsRequest.index())) {
    responses.set(i, new MultiTermVectorsItemResponse(null, new MultiTermVectorsResponse.Failure(termVectorsRequest.index(),

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

for (int i = 0; i < request.requests.size(); i++) {
  TermVectorsRequest termVectorsRequest = request.requests.get(i);
  termVectorsRequest.routing(clusterState.metaData().resolveIndexRouting(termVectorsRequest.parent(), termVectorsRequest.routing(), termVectorsRequest.index()));
  if (!clusterState.metaData().hasConcreteIndex(termVectorsRequest.index())) {
    responses.set(i, new MultiTermVectorsItemResponse(null,

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  // update the routing (request#index here is possibly an alias or a parent)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  // update the routing (request#index here is possibly an alias or a parent)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  // update the routing (request#index here is possibly an alias or a parent)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  IndexMetaData indexMeta = state.getMetaData().index(request.concreteIndex());
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  IndexMetaData indexMeta = state.getMetaData().index(request.concreteIndex());
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  IndexMetaData indexMeta = state.getMetaData().index(request.concreteIndex());
  if (request.request().realtime && // if the realtime flag is set
      request.request().preference() == null && // the preference flag is not already set
      indexMeta != null && // and we have the index
      IndexMetaData.isIndexUsingShadowReplicas(indexMeta.getSettings())) { // and the index uses shadow replicas
    // set the preference for the request to use "_primary" automatically
    request.request().preference(Preference.PRIMARY.type());
  }
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().parent(), request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}

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

@Override
protected void resolveRequest(ClusterState state, InternalRequest request) {
  if (request.request().realtime == null) {
    request.request().realtime = this.realtime;
  }
  IndexMetaData indexMeta = state.getMetaData().index(request.concreteIndex());
  if (request.request().realtime && // if the realtime flag is set
      request.request().preference() == null && // the preference flag is not already set
      indexMeta != null && // and we have the index
      IndexMetaData.isIndexUsingShadowReplicas(indexMeta.getSettings())) { // and the index uses shadow replicas
    // set the preference for the request to use "_primary" automatically
    request.request().preference(Preference.PRIMARY.type());
  }
  // update the routing (request#index here is possibly an alias)
  request.request().routing(state.metaData().resolveIndexRouting(request.request().routing(), request.request().index()));
  // Fail fast on the node that received the request.
  if (request.request().routing() == null && state.getMetaData().routingRequired(request.concreteIndex(), request.request().type())) {
    throw new RoutingMissingException(request.concreteIndex(), request.request().type(), request.request().id());
  }
}