tests.system.apache.beam.example_java_dataflow¶

用于 Apache Beam operators 的 Airflow DAG 示例

属性¶

`jar_to_local_dataflow_runner`
`test_run`

tests.system.apache.beam.example_java_dataflow.jar_to_local_dataflow_runner[源码]¶