diff --git a/CHANGELOG.md b/CHANGELOG.md index 84398bbad5..2302733136 100644 --- 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 index 1613dc9311..21f6e88727 100644 --- 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 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);