tests.system.apache.beam.example_go_dataflow

用于 Apache Beam 运算符的示例 Airflow DAG

模块内容

tests.system.apache.beam.example_go_dataflow.start_go_job_dataflow_runner_async[source]
tests.system.apache.beam.example_go_dataflow.test_run[source]

此条目是否有帮助?