示例 DAG 演示 PigOperator 的用法。
模块内容
-
tests.system.apache.pig.example_pig.ENV_ID[源代码]
-
tests.system.apache.pig.example_pig.DAG_ID = 'example_adf_run_pipeline'[源代码]
-
tests.system.apache.pig.example_pig.run_this[源代码]
-
tests.system.apache.pig.example_pig.test_run[源代码]