ElasticSearch Java API Client - Create index with type mapping

sweller · July 24, 2024, 4:57pm

I am migrating some code which uses the old rest high level client to the Java API Client (Starting at 7.17.22 with plans to migrate to 8.X immediately after), and am trying to recreate the mapping for a CreateIndexRequest that was originally built with the now removed XContentBuilder class

My old code:

XContentBuilder mapping = null;
            mapping = jsonBuilder()
                    .startObject()
                        .startObject("settings").value(esIndexSettings).endObject()
                        .startObject("mappings")
                            .startObject(DEFAULT_TYPE).field("date_detection", false)
                                .startObject("properties")
                                    .startObject("action").field("type", "text").endObject()
                                    .startObject("deltas")
                                        .startObject("properties")
                                            .startObject("current").field("type", "text").endObject()
                                            .startObject("previous").field("type", "text").endObject()
                                            .startObject("propertyName").field("type", "text").endObject()
                                        .endObject()
                                    .endObject()
                                    .startObject("entityId").field("type", "long").endObject()
                                    .startObject("entityType").field("type", "text").endObject()
                                    .startObject("parentId").field("type", "long").endObject()
                                    .startObject("parentLevel").field("type", "text").endObject()
                                    .startObject("timestamp").field("type", "date").endObject()
                                    .startObject("type").field("type", "text").endObject()
                                    .startObject("userId").field("type", "long").endObject()
                                    .startObject("userName").field("type", "text").endObject()
                                    .startObject("userLogin").field("type", "text").endObject()
                                .endObject()
                            .endObject()
                        .endObject()
                    .endObject();

My current attempt:

CreateIndexRequest request = new CreateIndexRequest.Builder()
                        .index(indexName)
                        .mappings(new TypeMapping.Builder()
                                .dateDetection(false)
                                .properties(Map.of(
                                        // I get stuck here. Not sure how to properly configure fields
                                        "action", new Property.Builder()
                                                .text(new TextProperty.Builder().build())
                                                .build(),
                                        "deltas", new AggregateMetricDoubleProperty.Builder().build()._toProperty()
                                ))
                                .build())
                        .settings(new IndexSettings.Builder()
                                .build())
                        .build();

dadoonet · July 24, 2024, 9:14pm

Welcome!

Have a look at this blog post which describes a bit how to use the new client and some tips on migrating from the old one.

Also this repository contains lot of tests demoing the Java client in action.

For example:

github.com

dadoonet/elasticsearch-java-client-demo/blob/49011c27dbbb5b989441df3c45a3ff9cf1200a6e/src/test/java/fr/pilato/test/elasticsearch/hlclient/EsClientIT.java#L576


      
              assertEquals(0.0, hit1.sort().get(0).doubleValue());
              Hit<Person> hit2 = response.hits().hits().get(1);
              assertEquals("2", hit2.id());
              assertEquals(1, hit2.sort().size());
              assertEquals(8187.4318605250455, hit2.sort().get(0).doubleValue());
          }
          
          @Test
          void geoPointSearch() throws IOException {
              client.indices().create(cir -> cir.index(indexName));
              client.indices().putMapping(pmr -> pmr.index(indexName).properties("location", p -> p.geoPoint(gp -> gp)));
              Person p1 = new Person();
              p1.setId("1");
              p1.setName("Foo");
              p1.setLocation(new GeoPoint(49.0404, 2.0174));
              Person p2 = new Person();
              p2.setId("2");
              p2.setName("Bar");
              p2.setLocation(new GeoPoint(38.7330, -109.8774));
              client.index(ir -> ir.index(indexName).id(p1.getId()).document(p1));
              client.index(ir -> ir.index(indexName).id(p2.getId()).document(p2));

Topic		Replies	Views
Elasticsearch index mapping in java Elasticsearch	7	2304	July 6, 2017
Creating Indexes with proper mapping in ES 5.0 on Java API Elasticsearch	15	7812	December 26, 2016
Java API - Create index/mapping examples Elasticsearch	3	2947	July 6, 2017
Proposed way to use Elasticsearch Java API Client to generate requests Elasticsearch	1	656	November 19, 2022
Creating Indices with types using Java API Elasticsearch	6	436	March 6, 2019

ElasticSearch Java API Client - Create index with type mapping

Related Topics