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[原始碼]

此條目有幫助嗎?