• Home
• Index

Index

_

__version__ (in module airflow.providers.apache.livy)

A

airflow.providers.apache.livy module airflow.providers.apache.livy.get_provider_info module airflow.providers.apache.livy.hooks module airflow.providers.apache.livy.hooks.livy module airflow.providers.apache.livy.operators module airflow.providers.apache.livy.operators.livy module

airflow.providers.apache.livy.sensors module airflow.providers.apache.livy.sensors.livy module airflow.providers.apache.livy.triggers module airflow.providers.apache.livy.triggers.livy module airflow.providers.apache.livy.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.apache.livy.version_compat)

B

batch_id (airflow.providers.apache.livy.sensors.livy.LivySensor attribute) BatchState (class in airflow.providers.apache.livy.hooks.livy)

build_post_batch_body() (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook static method) (airflow.providers.apache.livy.hooks.livy.LivyHook static method) BUSY (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

C

conn_name_attr (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

conn_type (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

D

DAG_ID (in module tests.system.apache.livy.example_livy) DEAD (airflow.providers.apache.livy.hooks.livy.BatchState attribute) default_conn_name (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

default_headers (airflow.providers.apache.livy.hooks.livy.LivyHook attribute) deferrable (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) delete_batch() (airflow.providers.apache.livy.hooks.livy.LivyHook method) dump_batch_logs() (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook method) (airflow.providers.apache.livy.hooks.livy.LivyHook method)

E

endpoint_prefix (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute) ENV_ID (in module tests.system.apache.livy.example_livy) ERROR (airflow.providers.apache.livy.hooks.livy.BatchState attribute) execute() (airflow.providers.apache.livy.operators.livy.LivyOperator method)

execute_complete() (airflow.providers.apache.livy.operators.livy.LivyOperator method) extra_headers (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute) extra_options (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

G

get_batch() (airflow.providers.apache.livy.hooks.livy.LivyHook method) get_batch_logs() (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook method) (airflow.providers.apache.livy.hooks.livy.LivyHook method)

get_batch_state() (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook method) (airflow.providers.apache.livy.hooks.livy.LivyHook method) get_hook() (airflow.providers.apache.livy.sensors.livy.LivySensor method) get_provider_info() (in module airflow.providers.apache.livy.get_provider_info)

H

hook (airflow.providers.apache.livy.operators.livy.LivyOperator property) hook_name (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

http_conn_id (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

I

IDLE (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

K

kill() (airflow.providers.apache.livy.operators.livy.LivyOperator method)

KILLED (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

L

livy_java_task (in module tests.system.apache.livy.example_livy) LivyAsyncHook (class in airflow.providers.apache.livy.hooks.livy) LivyHook (class in airflow.providers.apache.livy.hooks.livy)

LivyOperator (class in airflow.providers.apache.livy.operators.livy) LivySensor (class in airflow.providers.apache.livy.sensors.livy) LivyTrigger (class in airflow.providers.apache.livy.triggers.livy)

M

method (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute) module airflow.providers.apache.livy airflow.providers.apache.livy.get_provider_info airflow.providers.apache.livy.hooks airflow.providers.apache.livy.hooks.livy airflow.providers.apache.livy.operators airflow.providers.apache.livy.operators.livy airflow.providers.apache.livy.sensors airflow.providers.apache.livy.sensors.livy airflow.providers.apache.livy.triggers airflow.providers.apache.livy.triggers.livy airflow.providers.apache.livy.version_compat tests.system.apache.livy tests.system.apache.livy.example_livy

N

NOT_STARTED (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

O

on_kill() (airflow.providers.apache.livy.operators.livy.LivyOperator method)

openlineage_inject_parent_job_info (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) openlineage_inject_transport_info (airflow.providers.apache.livy.operators.livy.LivyOperator attribute)

P

poke() (airflow.providers.apache.livy.sensors.livy.LivySensor method) poll_for_termination() (airflow.providers.apache.livy.operators.livy.LivyOperator method) (airflow.providers.apache.livy.triggers.livy.LivyTrigger method)

post_batch() (airflow.providers.apache.livy.hooks.livy.LivyHook method)

R

retry_args (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) run() (airflow.providers.apache.livy.triggers.livy.LivyTrigger method)

run_method() (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook method) (airflow.providers.apache.livy.hooks.livy.LivyHook method) RUNNING (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

S

sanitize_endpoint_prefix() (in module airflow.providers.apache.livy.hooks.livy) serialize() (airflow.providers.apache.livy.triggers.livy.LivyTrigger method) SHUTTING_DOWN (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

spark_params (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) (airflow.providers.apache.livy.triggers.livy.LivyTrigger attribute) STARTING (airflow.providers.apache.livy.hooks.livy.BatchState attribute) SUCCESS (airflow.providers.apache.livy.hooks.livy.BatchState attribute)

T

template_fields (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) (airflow.providers.apache.livy.sensors.livy.LivySensor attribute) template_fields_renderers (airflow.providers.apache.livy.operators.livy.LivyOperator attribute) TERMINAL_STATES (airflow.providers.apache.livy.hooks.livy.LivyAsyncHook attribute) (airflow.providers.apache.livy.hooks.livy.LivyHook attribute)

test_run (in module tests.system.apache.livy.example_livy) tests.system.apache.livy module tests.system.apache.livy.example_livy module

PreviousNext

Was this entry helpful?