• Home
• Index

Index

_

__version__ (in module airflow.providers.alibaba)

A

adb_spark_conn (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) adb_spark_conn_id (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) 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 airflow.providers.alibaba.get_provider_info 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) app_id (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator attribute) (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor attribute) append_string() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) AppState (class in airflow.providers.alibaba.cloud.hooks.analyticdb_spark)

B

bucket_key (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute) bucket_name (airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator attribute) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute)

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) closed (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute) 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_local_copy (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute) 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) file (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator 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_provider_info() (in module airflow.providers.alibaba.get_provider_info) 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 property) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator property) (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor property) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor property)

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

K

key (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator attribute) key_exist() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)

keys (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator attribute) 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)

log_relative_path (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute)

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 airflow.providers.alibaba.get_provider_info 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_conn (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute) oss_conn_id (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator attribute) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute)

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) polling_interval (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator attribute) provide_bucket_name() (in module airflow.providers.alibaba.cloud.hooks.oss)

R

read_key() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method) region (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook attribute) (airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator attribute) (airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator attribute) (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute)

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_params (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator attribute) (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator attribute) 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) upload_on_close (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute)

PreviousNext

Was this entry helpful?