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]

Was this entry helpful?