Re: ElasticsearchIO delete document

Hi Jithin, Updating Beam to 2.25.0 and using "withIsDeleteFn" works as expected. Thanks a lot for the detailed answer! Best, Arif On Tue, Dec 1, 2020 at 11:30 AM JITHIN SUKUMAR wrote: > Hi Arif Alili, > > Deleting documents using ElasticsearchIO [1] was included in Apache Beam > since version

Re: ElasticsearchIO delete document

Hi Arif Alili, Deleting documents using ElasticsearchIO [1] was included in Apache Beam since version 2.25.0 [2]. You can check out the javadoc [3] or some example implementations [4]. References: [1]: https://issues.apache.org/jira/browse/BEAM-5757 [2]: https://beam.apache.org/blog/beam-2.25.0/

ElasticsearchIO delete document

Hi all, I am writing to Elasticsearch using Beam (Google Dataflow) class ElasticsearchIO. Creating indexes and writing document goes well, however, I am struggling to find a way to delete Elasticsearch documents, looking at this documentation https://beam.apache.org/releases/javadoc/2.5.0/org/apac