Adding an example for bulk update operation (#690) (#693)

* Adding an example for bulk update operation * updated the changelog.md * changes made by spotlessApply * removing CommonUtil based on review comments * reverting files to original state * changes by spotlessApply * removing static fields and unnecessary waits * changes as per review comments * removing unnecessary changes --------- (cherry picked from commit 25bd4cf) Signed-off-by: Karthik Subramanian <[email protected]> Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com> Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
opensearch-project · Oct 27, 2023 · a4f313b · a4f313b
1 parent 42b592c
commit a4f313b
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,7 +7,8 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ### Dependencies
 
 ### Changed
-Allow null values in arrays ([#687](https://github.com/opensearch-project/opensearch-java/pull/687))
+- Allow null values in arrays ([#687](https://github.com/opensearch-project/opensearch-java/pull/687))
+- Add an example for bulk update operation in samples ([#690](https://github.com/opensearch-project/opensearch-java/pull/690))
 
 ### Deprecated
 

diff --git a/samples/src/main/java/org/opensearch/client/samples/Bulk.java b/samples/src/main/java/org/opensearch/client/samples/Bulk.java
@@ -77,9 +77,18 @@ public static void main(String[] args) {
                 .source(sc -> sc.fetch(false))
                 .ignoreThrottled(false)
                 .query(query);
+
             SearchResponse<IndexData> searchResponse = client.search(searchReq.build(), IndexData.class);
             LOGGER.info("Found {} documents", searchResponse.hits().hits().size());
 
+            LOGGER.info("Bulk update document");
+            doc1.setText("Updated Document");
+            BulkRequest request = new BulkRequest.Builder().operations(o -> o.update(u -> u.index(indexName).id("id1").document(doc1)))
+                .refresh(Refresh.WaitFor)
+                .build();
+            bulkResponse = client.bulk(request);
+            LOGGER.info("Bulk update response items: {}", bulkResponse.items().size());
+
             LOGGER.info("Deleting index {}", indexName);
             DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest.Builder().index(indexName).build();
             client.indices().delete(deleteIndexRequest);