Создание индексов с отображением в ES 6.5 на Java REST Client [6.5] API

Question

Я новичок в упругом поиске и пытаюсь интегрировать функцию автозаполнения для приложения, следуя статье https://www.elastic.co/blog/you-complete-me.

Я следовал приведенному ниже подходу, чтобы сделать то же самое.

Событиеclass

       public class Event {

        private Long eventId;
        private Long catalogId;
        private Long orgId;
        private String orgName;
        private String catalogName;
        private String name;
        private String eventStatus;
.....
    }

Objectmapper используется для преобразования объекта события в строку json.Вот код для вставки документа

public String createEventDocument(Event document) throws Exception {
    IndexRequest indexRequest = new IndexRequest(INDEX, TYPE, document.idAsString())
            .source(convertEventDocumentToMap(document));
    //create mapping with a complete field
    IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
    return indexResponse.getResult().name();
}

Код преобразования

private Map<String, Object> convertEventDocumentToMap(Event evt) {
    return objectMapper.convertValue(evt, Map.class);
}

Я хотел бы создать индекс и настроить подсказку завершения для поля name_suggest.Как я могу добиться того же?

Любая помощь приветствуется

Answer 1

Вот решение сделать то же самое. Сначала создайте индекс с помощью картографов и вставьте данные

 public String createEventDocument(Event document) throws Exception {
    GetIndexRequest request = new GetIndexRequest();
    request.indices(INDEX);
    boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
    if(!exists){
        createIndexWithMapping();
    }
    IndexRequest indexRequest = new IndexRequest(INDEX, TYPE, document.idAsString())
            .source(convertEventDocumentToMap(document));
    //create mapping with a complete field
    IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
    return indexResponse.getResult().name();
}

private boolean createIndexWithMapping() throws IOException {
            CreateIndexRequest createIndexRequest = new CreateIndexRequest(INDEX);
    XContentBuilder builder = XContentFactory.jsonBuilder();
    builder.startObject();
    {
        builder.startObject( "properties" );
        {
            builder.startObject( "name_suggest" );
            {
                builder.field( "type", "completion" );
            }
            builder.endObject();
        }
        builder.endObject();
    }
    builder.endObject();
    createIndexRequest.mapping(TYPE,builder);
    createIndexRequest.timeout(TimeValue.timeValueMinutes(2));
    CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
    return createIndexResponse.isAcknowledged();

}

Answer 2

Вы можете сделать что-то вроде,

public static void main( String[] args )
    {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost( "192.168.1.245", 9200, "http" ) ) );
        try
        {
            createIndex( client );
            updateIndexMapping( client );
        }
        catch ( Exception e )
        {
            e.printStackTrace();
        }
    }

    private static void createIndex( RestHighLevelClient client ) throws IOException
    {

        //1. create index
        Map<String, String> map = new HashMap<String, String>();
        map.put( "eventId", "eventId" );
        map.put( "catalogId", "catalogId" );
        map.put( "orgId", "orgId" );
        map.put( "orgName", "orgName" );
        map.put( "catalogName", "catalogName" );
        map.put( "name", "name" );
        map.put( "eventStatus", "eventStatus" );

        IndexRequest indexRequest = new IndexRequest( "event", "event", "123" )
                .source( map );

        IndexResponse indexResponse = client.index( indexRequest, RequestOptions.DEFAULT );
        indexResponse.getResult().name();
    }

    private static void updateIndexMapping( RestHighLevelClient client ) throws IOException
    {
        //2. update index mapping to set the filed 'name_suggest' into type 'completion'
        PutMappingRequest request = new PutMappingRequest( "event" );
        request.type( "event" );

        XContentBuilder builder = XContentFactory.jsonBuilder();
        builder.startObject();
        {
            builder.startObject( "properties" );
            {
                builder.startObject( "name_suggest" );
                {
                    builder.field( "type", "completion" );
                }
                builder.endObject();
            }
            builder.endObject();
        }
        builder.endObject();
        request.source( builder );
        request.timeout( TimeValue.timeValueMinutes( 1 ) );

        AcknowledgedResponse acknowledgedResponse = client.indices().putMapping( request, RequestOptions.DEFAULT );

        //check if the request is sucess
        boolean acknowledged = acknowledgedResponse.isAcknowledged();
    }