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/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.html, I see there's only read() and write() methods.
Anyone has any suggestions how to delete Elasticsearch documents using Beam's ElasticsearchIO? Best, Arif
