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

IndexMetaData.mappingOrDefault介绍

[英]Sometimes, the default mapping exists and an actual mapping is not created yet (introduced), in this case, we want to return the default mapping in case it has some default mapping definitions.

Note, once the mapping type is introduced, the default mapping is applied on the actual typed MappingMetaData, setting its routing, timestamp, and so on if needed.
[中]有时，默认映射存在，而实际映射尚未创建（引入），在这种情况下，我们希望返回默认映射，以防它具有一些默认映射定义。
注意，一旦引入映射类型，默认映射将应用于实际类型化的MappingMetaData，并根据需要设置其路由、时间戳等。

代码示例

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

IndexRequest indexRequest = (IndexRequest) docWriteRequest;
final IndexMetaData indexMetaData = metaData.index(concreteIndex);
MappingMetaData mappingMd = indexMetaData.mappingOrDefault(indexRequest.type());
Version indexCreated = indexMetaData.getCreationVersion();
indexRequest.resolveRouting(metaData);

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

IndexRequest indexRequest = updateResult.action();
IndexMetaData metaData = context.getPrimary().indexSettings().getIndexMetaData();
MappingMetaData mappingMd = metaData.mappingOrDefault(indexRequest.type());
indexRequest.process(metaData.getCreationVersion(), mappingMd, updateRequest.concreteIndex());
context.setRequestToExecute(indexRequest);

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

@Override
protected void resolveRequest(MetaData metaData, String concreteIndex, IndexRequest request) {
  MappingMetaData mappingMd = null;
  if (metaData.hasIndex(concreteIndex)) {
    mappingMd = metaData.index(concreteIndex).mappingOrDefault(request.type());
  }
  request.process(metaData, mappingMd, allowIdGeneration, concreteIndex);
  ShardId shardId = clusterService.operationRouting().shardId(clusterService.state(), concreteIndex, request.type(), request.id(), request.routing());
  request.setShardId(shardId);
}

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

MappingMetaData mappingMd = null;
if (metaData.hasIndex(concreteIndex)) {
  mappingMd = metaData.index(concreteIndex).mappingOrDefault(indexRequest.type());

代码示例来源：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

private WriteResult<IndexResponse> shardIndexOperation(BulkShardRequest request, IndexRequest indexRequest, MetaData metaData,
                    IndexShard indexShard, boolean processed) throws Throwable {
  // validate, if routing is required, that we got routing
  MappingMetaData mappingMd = metaData.index(request.index()).mappingOrDefault(indexRequest.type());
  if (mappingMd != null && mappingMd.routing().required()) {
    if (indexRequest.routing() == null) {
      throw new RoutingMissingException(request.index(), indexRequest.type(), indexRequest.id());
    }
  }
  if (!processed) {
    indexRequest.process(metaData, mappingMd, allowIdGeneration, request.index());
  }
  return TransportIndexAction.executeIndexRequestOnPrimary(request, indexRequest, indexShard, mappingUpdatedAction);
}

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

IndexRequest indexRequest = (IndexRequest) docWriteRequest;
final IndexMetaData indexMetaData = metaData.index(concreteIndex);
MappingMetaData mappingMd = indexMetaData.mappingOrDefault(indexRequest.type());
Version indexCreated = indexMetaData.getCreationVersion();
indexRequest.resolveRouting(metaData);

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

final IndexMetaData indexMetaData = metaData.index(concreteIndex);
if (indexMetaData != null) {
  mappingMd = indexMetaData.mappingOrDefault(indexRequest.type());

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

IndexRequest indexRequest = (IndexRequest) docWriteRequest;
final IndexMetaData indexMetaData = metaData.index(concreteIndex);
MappingMetaData mappingMd = indexMetaData.mappingOrDefault(indexRequest.type());
Version indexCreated = indexMetaData.getCreationVersion();
indexRequest.resolveRouting(metaData);

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

case UPDATED:
  IndexRequest indexRequest = translate.action();
  MappingMetaData mappingMd = metaData.mappingOrDefault(indexRequest.type());
  indexRequest.process(metaData.getCreationVersion(), mappingMd, concreteIndex);
  result = executeIndexRequestOnPrimary(indexRequest, primary, mappingUpdater);

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

@Override
protected Tuple<IndexResponse, IndexRequest> shardOperationOnPrimary(MetaData metaData, IndexRequest request) throws Throwable {
  // validate, if routing is required, that we got routing
  IndexMetaData indexMetaData = metaData.index(request.shardId().getIndex());
  MappingMetaData mappingMd = indexMetaData.mappingOrDefault(request.type());
  if (mappingMd != null && mappingMd.routing().required()) {
    if (request.routing() == null) {
      throw new RoutingMissingException(request.shardId().getIndex(), request.type(), request.id());
    }
  }
  IndexService indexService = indicesService.indexServiceSafe(request.shardId().getIndex());
  IndexShard indexShard = indexService.shardSafe(request.shardId().id());
  final WriteResult<IndexResponse> result = executeIndexRequestOnPrimary(null, request, indexShard, mappingUpdatedAction);
  final IndexResponse response = result.response;
  final Translog.Location location = result.location;
  processAfterWrite(request.refresh(), indexShard, location);
  return new Tuple<>(response, request);
}

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

IndexRequest indexRequest = updateResult.action();
IndexMetaData metaData = context.getPrimary().indexSettings().getIndexMetaData();
MappingMetaData mappingMd = metaData.mappingOrDefault(indexRequest.type());
indexRequest.process(metaData.getCreationVersion(), mappingMd, updateRequest.concreteIndex());
context.setRequestToExecute(indexRequest);

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

case UPDATED:
  IndexRequest indexRequest = translate.action();
  MappingMetaData mappingMd = metaData.mappingOrDefault(indexRequest.type());
  indexRequest.process(mappingMd, allowIdGeneration, request.index());
  updateOperationResult = executeIndexRequestOnPrimary(indexRequest, primary, mappingUpdatedAction, this.clusterService, this.indicesService, metaData);