tests.system.apache.livy.example_livy
這是一個使用 LivyOperator 的示例 DAG。下面的任務使用示例庫中提供的 Java 和 Python 可執行檔案,在 Spark 例項上觸發計算 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[原始碼]