tests.system.apache.beam.example_beam_java_spark

Apache Beam 运算符的 Airflow 示例 DAG

属性

jar_to_local_spark_runner

test_run

模块内容

tests.system.apache.beam.example_beam_java_spark.jar_to_local_spark_runner[源]
tests.system.apache.beam.example_beam_java_spark.test_run[源]

此条目有帮助吗？