[BEAM-7916] Add ElasticsearchIO query parameter to take a ValueProvider

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.14.0
• Fix Version/s: 2.16.0
• Component/s: io-java-elasticsearch
• Assignee: Alexey Romanenko
• Reporter: Oliver Henlich
• Created: 07/Aug/19 05:50
• Updated: 16/May/20 13:33
• Resolved: 14/Aug/19 08:32

Description

We need to be able to perform Elasticsearch queries that are dynamic. The problem is ElasticsearchIO.read().withQuery() only accepts a string which means the query must be known when the pipleline/Google Dataflow Template is built.

It would be great if we could change the parameter on the withQuery() method from String to ValueProvider<String>.

Pull request: https://github.com/apache/beam/pull/9285

Issue Links

• links to: GitHub Pull Request #9285
• links to: GitHub Pull Request #9305
• links to: GitHub Pull Request #9314