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
How to define mappings using Java API Elasticsearch	4	1815	July 6, 2017
Creating Indexes with proper mapping in ES 5.0 on Java API Elasticsearch	15	7814	December 26, 2016
Creating mappings via the Java API Elasticsearch	9	2528	July 6, 2017
Bug in Java PutMapping API? Elasticsearch	4	456	July 6, 2017

ElasticSearch Java API Client - Create index with type mapping

Related topics