tests.system.apache.beam.example_python

用於 Apache Beam 運算子的範例 Airflow DAG

模組內容

tests.system.apache.beam.example_python.start_python_pipeline_local_direct_runner[source]
tests.system.apache.beam.example_python.test_run[source]

這個條目是否有幫助?