How to do bulk update using elasticsearchOperations in Spring data elasticsearch?

Question

We were doing bullk insert by using bulkIndex as follow:

List<IndexQuery> indexQueries = new ArrayList<>();
        for (FooDocument fooDocument : fooDocuments) {
            IndexQuery query = new IndexQueryBuilder()
                    .withId(String.valueOf(fooDocument.getId()))
                    .withObject(fooDocument)
                    .build();
            indexQueries.add(query);
        }
    elasticsearchOperations.bulkIndex(indexQueries, IndexCoordinates.of("foo_index_3"));

We also want to use for bulk updates something like:

elasticsearchOperations.bulkUpdate(updateQueries, IndexCoordinates.of("foo_index_3"));

But bulkUpdate requires list of UpdateQuery.I am trying to create it by doing something like:

List<IndexQuery> updateQueries = new ArrayList<>();
        for (FooDocument fooDocument : fooDocuments) {
            UpdateQuery updateQuery = new UpdateQueryBuilder()//which Builder class and method is required?
                    .withId(String.valueOf(fooDocument.getId()))
                    .withObject(fooDocument)
                    .build();
            updateQueries.add(query);
        }

But unlike IndexQueryBuilder there is no UpdateQueryBuilder() available, what is the correct way to build the UpdateQuery and which Builder class should we use? I am wondering whether UpdateQueryBuilder class has been deprecated.

P.S: we are using 4.0.2.RELEASE version of spring-data-elasticsearch

@Val, I am not aware about how to build it using it, all I have is id and Document as in IndexyQuery, was wondering whether same is possible with UpdateQuery, If you could provide the sample, that would be really helpful. — implosivesilence
– implosivesilence, Commented Nov 19, 2020 at 14:42
@Val, we are using it for insertion, kinda updating like all fields, due to some reason, cannot use bulkIndex — implosivesilence
– implosivesilence, Commented Nov 19, 2020 at 14:50
Since you're updating all fields, why don't you simply reindex the document with IndexQuery instead? — Val
– Val, Commented Nov 19, 2020 at 14:52

Abacus · Accepted Answer · 2020-11-19 17:57:45Z

2

You create an UpdateQuery with a builder like this:

UpdateQuerybuilder builder = UpdateQuery.builder(id)
   .with(...)
   .build();

Here the builder is a nested class and not a separate one.

answered Nov 19, 2020 at 17:57

Abacus

19.6k7 gold badges54 silver badges71 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to do bulk update using elasticsearchOperations in Spring data elasticsearch?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related