tests.system.apache.beam.example_java_dataflow
Example Airflow DAG for Apache Beam operators
Module Contents
-
tests.system.apache.beam.example_java_dataflow.jar_to_local_dataflow_runner[source]
-
tests.system.apache.beam.example_java_dataflow.test_run[source]