Send a blocking bulk index request via the Elasticsearch Java client (8.9)

dadoonet · August 17, 2023, 1:30pm

Welcome!

Don't forget to call refresh before counting/searching.

See

dadoonet/elasticsearch-java-client-demo/blob/be89f7cc7530cebfaeadc7c5e9bf109c71ee4caa/src/test/java/fr/pilato/test/elasticsearch/hlclient/EsClientIT.java#L396-L419


      
          void bulk() throws IOException {
              int size = 1_000;
              try {
                  client.indices().delete(dir -> dir.index("bulk"));
              } catch (ElasticsearchException ignored) { }
          
              BinaryData data = BinaryData.of("{\"foo\":\"bar\"}".getBytes(StandardCharsets.UTF_8), ContentType.APPLICATION_JSON);
              BulkResponse response = client.bulk(br -> {
                  br.index("bulk");
                  for (int i = 0; i < size; i++) {
                      br.operations(o -> o.index(ir -> ir.document(data)));
                  }
                  return br;
              });
              logger.info("bulk executed in {} ms {} errors", response.errors() ? "with" : "without", response.ingestTook());
              if (response.errors()) {
                  response.items().stream().filter(p -> p.error() != null)
                          .forEach(item -> logger.error("Error {} for id {}", item.error().reason(), item.id()));
              }

This file has been truncated. show original

Specifically this line:

client.indices().refresh(rr -> rr.index("bulk"));

Topic		Replies	Views
Bulk indexing and count mismatch Elasticsearch	7	1600	July 6, 2017
Bulk Request not fully indexing data in synchronised request Elasticsearch	1	795	January 4, 2017
Java Bulk indexing API performances Elasticsearch	3	334	July 6, 2017
Bulk update with java API Elasticsearch	3	2491	July 6, 2017
Elastic search PHP: wait for bulk indexation to finish Elasticsearch	5	1439	April 30, 2018

Send a blocking bulk index request via the Elasticsearch Java client (8.9)

Related topics