tests.system.apache.livy.example_livy
This is an example DAG which uses the LivyOperator.
The tasks below trigger the computation of pi on the Spark instance
using the Java and Python executables provided in the example library.
Module Contents
-
tests.system.apache.livy.example_livy.ENV_ID[source]
-
tests.system.apache.livy.example_livy.DAG_ID = 'example_livy_operator'[source]
-
tests.system.apache.livy.example_livy.livy_java_task[source]
-
tests.system.apache.livy.example_livy.test_run[source]