Migrate Apache Beam JSON pipelines to PyFlink using native Elasticsearch connectors for efficient indexing on EMR or EKS.