Java TypeMissingException类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.elasticsearch.indices.TypeMissingException类的典型用法代码示例。如果您正苦于以下问题：Java TypeMissingException类的具体用法？Java TypeMissingException怎么用？Java TypeMissingException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

TypeMissingException类属于org.elasticsearch.indices包，在下文中一共展示了TypeMissingException类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testAutoCreateWithDisabledDynamicMappings

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
public void testAutoCreateWithDisabledDynamicMappings() throws Exception {
    assertAcked(client().admin().indices().preparePutTemplate("my_template")
        .setCreate(true)
        .setPatterns(Collections.singletonList("index_*"))
        .addMapping("foo", "field", "type=keyword")
        .setSettings(Settings.builder().put("index.mapper.dynamic", false).build())
        .get());

    // succeeds since 'foo' has an explicit mapping in the template
    indexRandom(true, false, client().prepareIndex("index_1", "foo", "1").setSource("field", "abc"));

    // fails since 'bar' does not have an explicit mapping in the template and dynamic template creation is disabled
    TypeMissingException e1 = expectThrows(TypeMissingException.class,
            () -> client().prepareIndex("index_2", "bar", "1").setSource("field", "abc").get());
    assertEquals("type[bar] missing", e1.getMessage());
    assertEquals("trying to auto create mapping, but dynamic mapping is disabled", e1.getCause().getMessage());

    // make sure no mappings were created for bar
    GetIndexResponse getIndexResponse = client().admin().indices().prepareGetIndex().addIndices("index_2").get();
    assertFalse(getIndexResponse.mappings().containsKey("bar"));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:22，代码来源:DynamicMappingIT.java

示例2: documentMapperWithAutoCreate

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
/**
 * Returns the document mapper created, including a mapping update if the
 * type has been dynamically created.
 */
public DocumentMapperForType documentMapperWithAutoCreate(String type) {
    DocumentMapper mapper = mappers.get(type);
    if (mapper != null) {
        return new DocumentMapperForType(mapper, null);
    }
    if (!dynamic) {
        throw new TypeMissingException(index(),
                new IllegalStateException("trying to auto create mapping, but dynamic mapping is disabled"), type);
    }
    mapper = parse(type, null, true);
    return new DocumentMapperForType(mapper, mapper.mapping());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:17，代码来源:MapperService.java

示例3: documentMapperWithAutoCreate

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
/**
 * Returns the document mapper created, including a mapping update if the
 * type has been dynamically created.
 */
public DocumentMapperForType documentMapperWithAutoCreate(String type) {
    DocumentMapper mapper = mappers.get(type);
    if (mapper != null) {
        return new DocumentMapperForType(mapper, null);
    }
    if (!dynamic) {
        throw new TypeMissingException(index, type, "trying to auto create mapping, but dynamic mapping is disabled");
    }
    mapper = parse(type, null, true);
    return new DocumentMapperForType(mapper, mapper.mapping());
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:16，代码来源:MapperService.java

示例4: delete

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
@Delete("/:type")
@Delete("/:type/")
public Payload delete(String type) {
	try {
		Credentials credentials = SpaceContext.checkAdminCredentials();
		Start.get().getElasticClient().deleteIndex(credentials.backendId(), type);
		DataAccessControl.delete(type);
	} catch (TypeMissingException ignored) {
	}
	return JsonPayload.success();
}

开发者ID:spacedog-io，项目名称:spacedog-server，代码行数:12，代码来源:SchemaResource.java

示例5: prepareRequest

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
    final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
    GetMappingsRequest getMappingsRequest = new GetMappingsRequest();
    getMappingsRequest.indices(indices).types(types);
    getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
    getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
    return channel -> client.admin().indices().getMappings(getMappingsRequest, new RestBuilderListener<GetMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetMappingsResponse response, XContentBuilder builder) throws Exception {

            ImmutableOpenMap<String, ImmutableOpenMap<String, MappingMetaData>> mappingsByIndex = response.getMappings();
            if (mappingsByIndex.isEmpty()) {
                if (indices.length != 0 && types.length != 0) {
                    return new BytesRestResponse(OK, builder.startObject().endObject());
                } else if (indices.length != 0) {
                    builder.close();
                    return new BytesRestResponse(channel, new IndexNotFoundException(indices[0]));
                } else if (types.length != 0) {
                    builder.close();
                    return new BytesRestResponse(channel, new TypeMissingException("_all", types[0]));
                } else {
                    return new BytesRestResponse(OK, builder.startObject().endObject());
                }
            }

            builder.startObject();
            for (ObjectObjectCursor<String, ImmutableOpenMap<String, MappingMetaData>> indexEntry : mappingsByIndex) {
                if (indexEntry.value.isEmpty()) {
                    continue;
                }
                builder.startObject(indexEntry.key);
                builder.startObject(Fields.MAPPINGS);
                for (ObjectObjectCursor<String, MappingMetaData> typeEntry : indexEntry.value) {
                    builder.field(typeEntry.key);
                    builder.map(typeEntry.value.sourceAsMap());
                }
                builder.endObject();
                builder.endObject();
            }

            builder.endObject();
            return new BytesRestResponse(OK, builder);
        }
    });
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:48，代码来源:RestGetMappingAction.java

示例6: handleRequest

import org.elasticsearch.indices.TypeMissingException; //导入依赖的package包/类
@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
    final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
    final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
    GetMappingsRequest getMappingsRequest = new GetMappingsRequest();
    getMappingsRequest.indices(indices).types(types);
    getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
    getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
    client.admin().indices().getMappings(getMappingsRequest, new RestBuilderListener<GetMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetMappingsResponse response, XContentBuilder builder) throws Exception {
            builder.startObject();
            ImmutableOpenMap<String, ImmutableOpenMap<String, MappingMetaData>> mappingsByIndex = response.getMappings();
            if (mappingsByIndex.isEmpty()) {
                if (indices.length != 0 && types.length != 0) {
                    return new BytesRestResponse(OK, builder.endObject());
                } else if (indices.length != 0) {
                    return new BytesRestResponse(channel, new IndexNotFoundException(indices[0]));
                } else if (types.length != 0) {
                    return new BytesRestResponse(channel, new TypeMissingException(new Index("_all"), types[0]));
                } else {
                    return new BytesRestResponse(OK, builder.endObject());
                }
            }

            for (ObjectObjectCursor<String, ImmutableOpenMap<String, MappingMetaData>> indexEntry : mappingsByIndex) {
                if (indexEntry.value.isEmpty()) {
                    continue;
                }
                builder.startObject(indexEntry.key, XContentBuilder.FieldCaseConversion.NONE);
                builder.startObject(Fields.MAPPINGS);
                for (ObjectObjectCursor<String, MappingMetaData> typeEntry : indexEntry.value) {
                    builder.field(typeEntry.key);
                    Map<String, Object> mapping = typeEntry.value.sourceAsMap();
                    if (mapping.containsKey("_meta")) {
                        ((Map<String, Object>)mapping.get("_meta")).put(MappingMetaData.MAPPING_VERSION, typeEntry.value.mappingVersion());
                    } else {
                        HashMap<String, Object> mappingMeta = new HashMap<>();
                        mappingMeta.put(MappingMetaData.MAPPING_VERSION, typeEntry.value.mappingVersion());
                        mapping.put("_meta", mappingMeta);
                    }
                    builder.map(mapping);
                }
                builder.endObject();
                builder.endObject();
            }

            builder.endObject();
            return new BytesRestResponse(OK, builder);
        }
    });
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:53，代码来源:RestGetMappingAction.java

注：本文中的org.elasticsearch.indices.TypeMissingException类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。