tests.system.apache.beam.example_beam_java_flink¶

Example Airflow DAG for Apache Beam operators

Attributes¶

`jar_to_local_flink_runner`
`test_run`

Module Contents¶

tests.system.apache.beam.example_beam_java_flink.jar_to_local_flink_runner[source]¶

tests.system.apache.beam.example_beam_java_flink.test_run[source]¶

Was this entry helpful?