tests.system.apache.livy.example_livy

这是一个使用 LivyOperator 的示例 DAG。下面的任务使用示例库中提供的 Java 和 Python 可执行文件,在 Spark 实例上触发计算 Pi 的操作。

属性

ENV_ID

DAG_ID

livy_java_task

test_run

模块内容

tests.system.apache.livy.example_livy.ENV_ID[源码]
tests.system.apache.livy.example_livy.DAG_ID = 'example_livy_operator'[源码]
tests.system.apache.livy.example_livy.livy_java_task[源码]
tests.system.apache.livy.example_livy.test_run[源码]

此条目有帮助吗?