• Home
• Index

Index

_

__version__ (in module airflow.providers.alibaba)

A

airflow.providers.alibaba module airflow.providers.alibaba.cloud module airflow.providers.alibaba.cloud.hooks module airflow.providers.alibaba.cloud.hooks.analyticdb_spark module airflow.providers.alibaba.cloud.hooks.oss module airflow.providers.alibaba.cloud.log module airflow.providers.alibaba.cloud.log.oss_task_handler module airflow.providers.alibaba.cloud.operators module

airflow.providers.alibaba.cloud.operators.analyticdb_spark module airflow.providers.alibaba.cloud.operators.oss module airflow.providers.alibaba.cloud.sensors module airflow.providers.alibaba.cloud.sensors.analyticdb_spark module airflow.providers.alibaba.cloud.sensors.oss_key module AnalyticDBSparkBaseOperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark) AnalyticDBSparkBatchOperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark) AnalyticDBSparkHook (class in airflow.providers.alibaba.cloud.hooks.analyticdb_spark) AnalyticDBSparkSensor (class in airflow.providers.alibaba.cloud.sensors.analyticdb_spark) AnalyticDBSparkSQLOperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark) append_string() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) AppState (class in airflow.providers.alibaba.cloud.hooks.analyticdb_spark)

B

build_submit_app_data() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook static method)

build_submit_sql_data() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook static method)

C

close() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) COMPLETED (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute) conn_name_attr (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute)

conn_type (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute) create_bucket (in module tests.system.alibaba.example_oss_bucket) create_bucket() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) create_object (in module tests.system.alibaba.example_oss_object)

D

DAG_ID (in module tests.system.alibaba.example_adb_spark_batch) (in module tests.system.alibaba.example_adb_spark_sql) (in module tests.system.alibaba.example_oss_bucket) (in module tests.system.alibaba.example_oss_object) default_conn_name (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute)

delete_bucket() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) delete_object() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) delete_objects() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) download_file() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

E

ENV_ID (in module tests.system.alibaba.example_adb_spark_batch) (in module tests.system.alibaba.example_adb_spark_sql) (in module tests.system.alibaba.example_oss_bucket) (in module tests.system.alibaba.example_oss_object) execute() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator method) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator method) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator method)

F

FAILED (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

FAILING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute) FATAL (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

G

get_adb_spark_client() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) get_bucket() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) get_conn() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) get_credential() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) get_default_region() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

get_hook (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor property) get_hook() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method) (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor method) get_spark_log() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) get_spark_state() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) get_spark_web_ui_address() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method)

H

head_key() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) hook() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method) (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor method) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor method)

hook_name (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute)

K

key_exist() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) kill() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method)

kill_spark_app() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) KILLED (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute) KILLING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

L

load_string() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

M

module airflow.providers.alibaba airflow.providers.alibaba.cloud airflow.providers.alibaba.cloud.hooks airflow.providers.alibaba.cloud.hooks.analyticdb_spark airflow.providers.alibaba.cloud.hooks.oss airflow.providers.alibaba.cloud.log airflow.providers.alibaba.cloud.log.oss_task_handler airflow.providers.alibaba.cloud.operators airflow.providers.alibaba.cloud.operators.analyticdb_spark airflow.providers.alibaba.cloud.operators.oss airflow.providers.alibaba.cloud.sensors airflow.providers.alibaba.cloud.sensors.analyticdb_spark airflow.providers.alibaba.cloud.sensors.oss_key tests.system.alibaba tests.system.alibaba.example_adb_spark_batch tests.system.alibaba.example_adb_spark_sql tests.system.alibaba.example_oss_bucket tests.system.alibaba.example_oss_object

monitor_application() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method)

O

object_exists() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) on_kill() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method) oss_log_exists() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) oss_read() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) oss_write() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) OSSCreateBucketOperator (class in airflow.providers.alibaba.cloud.operators.oss) OSSDeleteBatchObjectOperator (class in airflow.providers.alibaba.cloud.operators.oss)

OSSDeleteBucketOperator (class in airflow.providers.alibaba.cloud.operators.oss) OSSDeleteObjectOperator (class in airflow.providers.alibaba.cloud.operators.oss) OSSDownloadObjectOperator (class in airflow.providers.alibaba.cloud.operators.oss) OSSHook (class in airflow.providers.alibaba.cloud.hooks.oss) OSSKeySensor (class in airflow.providers.alibaba.cloud.sensors.oss_key) OSSTaskHandler (class in airflow.providers.alibaba.cloud.log.oss_task_handler) OSSUploadObjectOperator (class in airflow.providers.alibaba.cloud.operators.oss)

P

parse_oss_url() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook static method) poke() (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor method) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor method)

poll_for_termination() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method) provide_bucket_name() (in module airflow.providers.alibaba.cloud.hooks.oss)

R

read_key() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

REGION (in module tests.system.alibaba.example_oss_bucket) RUNNING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

S

set_context() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler method) show_databases (in module tests.system.alibaba.example_adb_spark_sql) spark_pi (in module tests.system.alibaba.example_adb_spark_batch) STARTING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

submit_spark_app() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) submit_spark_sql() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method) SUBMITTED (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute) SUCCEEDING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)

T

T (in module airflow.providers.alibaba.cloud.hooks.oss) template_fields (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator attribute) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator attribute) (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor attribute) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute) template_fields_renderers (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator attribute) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator attribute) TERMINAL_STATES (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) test_run (in module tests.system.alibaba.example_adb_spark_batch) (in module tests.system.alibaba.example_adb_spark_sql) (in module tests.system.alibaba.example_oss_bucket) (in module tests.system.alibaba.example_oss_object)

tests.system.alibaba module tests.system.alibaba.example_adb_spark_batch module tests.system.alibaba.example_adb_spark_sql module tests.system.alibaba.example_oss_bucket module tests.system.alibaba.example_oss_object module

U

unify_bucket_name_and_key() (in module airflow.providers.alibaba.cloud.hooks.oss)

UNKNOWN (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute) upload_local_file() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

PreviousNext

Was this entry helpful?