Adding an example for bulk update operation (opensearch-project#690)

* Adding an example for bulk update operation Signed-off-by: Karthik Subramanian <[email protected]> * updated the changelog.md Signed-off-by: Karthik Subramanian <[email protected]> * changes made by spotlessApply Signed-off-by: Karthik Subramanian <[email protected]> * removing CommonUtil based on review comments Signed-off-by: Karthik Subramanian <[email protected]> * reverting files to original state Signed-off-by: Karthik Subramanian <[email protected]> * changes by spotlessApply Signed-off-by: Karthik Subramanian <[email protected]> * removing static fields and unnecessary waits Signed-off-by: Karthik Subramanian <[email protected]> * changes as per review comments Signed-off-by: Karthik Subramanian <[email protected]> * removing unnecessary changes Signed-off-by: Karthik Subramanian <[email protected]> --------- Signed-off-by: Karthik Subramanian <[email protected]>
ls-urs-keller · Oct 27, 2023 · 25bd4cf · 25bd4cf
1 parent 9408cc2
commit 25bd4cf
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -35,7 +35,8 @@ This section is for maintaining a changelog for all breaking changes for the cli
 ### 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);