• Home
• Index

Index

_

_build_jdbc_application_arguments() (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook method) _build_spark_driver_kill_command() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _build_spark_submit_command() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _build_track_driver_status_command() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _create_spark_session() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) _get_hook() (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) _get_spark_binary_path() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method)

_mask_cmd() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _parse_arguments() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) _prepare_command() (airflow.providers.apache.spark.hooks.spark_sql.SparkSqlHook method) _process_spark_status_log() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _process_spark_submit_log() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _resolve_connection() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _resolve_jdbc_connection() (airflow.providers.apache.spark.hooks.spark_jdbc.SparkJDBCHook method) _resolve_should_track_driver_status() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method) _run_spark() (in module airflow.providers.apache.spark.hooks.spark_jdbc_script) _start_driver_status_tracking() (airflow.providers.apache.spark.hooks.spark_submit.SparkSubmitHook method)

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

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

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

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

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)

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)

U

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

PreviousNext

Was this entry helpful?