Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
2.14.0
-
None
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