tests.system.apache.livy.example_livy

這是一個範例 DAG,它使用 LivyOperator。 以下任務觸發在 Spark 實例上使用範例庫中提供的 Java 和 Python 可執行檔計算 pi。

模組內容

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

這個條目有幫助嗎?