对于BeamJava，您可以使用ElasticsearchIO。
将PCollection写入ElasticSearch的示例：

pipeline
    .apply(...)
    .apply(ElasticsearchIO.write().withConnectionConfiguration(
       ElasticsearchIO.ConnectionConfiguration.create("http://host:9200", "my-index", "my-type")
    )

重要说明，IO不支持update类型操作，write方法允许在Elastic中添加元素。
如果必须应用更新操作，则有3种解决方案：

• 使用具有重复项的写入和现有IO，并在Beam的单独流程输出中删除重复项，仅保留Elastic中的最后一个元素。例如，您可以使用DAG协调器并在Dataflow作业之后执行服务
• 将现有Elasticclient与update方法一起使用，并在ParDo中使用
• 使用update方法基于现有客户端开发您自己的IO

BeamPython本机不存在此IO。
您可以选中此link以获得Beam中现有IO的列表。