• Home
• Index

Index

A

airflow.providers.apache.spark module airflow.providers.apache.spark.hooks module airflow.providers.apache.spark.hooks.spark_jdbc module airflow.providers.apache.spark.hooks.spark_jdbc_script module airflow.providers.apache.spark.hooks.spark_sql module

airflow.providers.apache.spark.hooks.spark_submit module airflow.providers.apache.spark.operators module airflow.providers.apache.spark.operators.spark_jdbc module airflow.providers.apache.spark.operators.spark_sql module airflow.providers.apache.spark.operators.spark_submit module ALLOWED_SPARK_BINARIES (in module airflow.providers.apache.spark.hooks.spark_submit)

C

conn_name_attr (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook attribute) (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook attribute) (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook attribute)

conn_type (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook attribute) (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook attribute) (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook attribute)

D

DAG_ID (in module tests.system.providers.apache.spark.example_spark_dag) default_conn_name (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook attribute) (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook attribute) (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook attribute)

E

ENV_ID (in module tests.system.providers.apache.spark.example_spark_dag) execute() (airflow.providers.apache.spark.operators.spark_jdbc.SparkJDBCOperator method) (airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator method) (airflow.providers.apache.spark.operators.spark_submit.SparkSubmitOperator method)

G

get_conn() (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook method) (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook method) (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method)

get_ui_field_behaviour() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook static method)

H

hook_name (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook attribute) (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook attribute) (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook attribute)

K

kill() (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook method)

M

module airflow.providers.apache.spark airflow.providers.apache.spark.hooks airflow.providers.apache.spark.hooks.spark_jdbc airflow.providers.apache.spark.hooks.spark_jdbc_script airflow.providers.apache.spark.hooks.spark_sql airflow.providers.apache.spark.hooks.spark_submit airflow.providers.apache.spark.operators airflow.providers.apache.spark.operators.spark_jdbc airflow.providers.apache.spark.operators.spark_sql airflow.providers.apache.spark.operators.spark_submit tests.system.providers.apache.spark tests.system.providers.apache.spark.example_spark_dag

O

on_kill() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) (airflow.providers.apache.spark.operators.spark_jdbc.SparkJDBCOperator method) (airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator method) (airflow.providers.apache.spark.operators.spark_submit.SparkSubmitOperator method)

R

run_query() (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook method)

S

set_common_options() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) SPARK_READ_FROM_JDBC (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) spark_read_from_jdbc() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) SPARK_WRITE_TO_JDBC (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) spark_write_to_jdbc() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) SparkJDBCHook (class in airflow.providers.apache.spark.hooks.spark_jdbc) SparkJDBCOperator (class in airflow.providers.apache.spark.operators.spark_jdbc)

SparkSqlHook (class in airflow.providers.apache.spark.hooks.spark_sql) SparkSqlOperator (class in airflow.providers.apache.spark.operators.spark_sql) SparkSubmitHook (class in airflow.providers.apache.spark.hooks.spark_submit) SparkSubmitOperator (class in airflow.providers.apache.spark.operators.spark_submit) submit() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) submit_jdbc_job() (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook method) submit_job (in module tests.system.providers.apache.spark.example_spark_dag)

T

template_ext (airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator attribute) template_fields (airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator attribute) (airflow.providers.apache.spark.operators.spark_submit.SparkSubmitOperator attribute) template_fields_renderers (airflow.providers.apache.spark.operators.spark_sql.SparkSqlOperator attribute)

test_run (in module tests.system.providers.apache.spark.example_spark_dag) tests.system.providers.apache.spark module tests.system.providers.apache.spark.example_spark_dag module

U

ui_color (airflow.providers.apache.spark.operators.spark_submit.SparkSubmitOperator attribute)

PreviousNext

Was this entry helpful?