Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!
Community
Meetups
Documentation
Use Cases
Announcements
Blog
Ecosystem
Community
Meetups
Documentation
Use Cases
Announcements
Blog
Ecosystem
Content
Version:
3.1.0
Basics
Home
Changelog
Security
Guides
Connection types
Operators
Logging for Tasks
References
Python API
System tests
System Tests
Resources
Example DAGs
PyPI Repository
Installing from sources
Commits
Detailed list of commits
Version:
3.1.0
Basics
Home
Changelog
Security
Guides
Connection types
Operators
Logging for Tasks
References
Python API
System tests
System Tests
Resources
Example DAGs
PyPI Repository
Installing from sources
Commits
Detailed list of commits
Home
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
_
__version__ (in module airflow.providers.alibaba)
A
access_key_id (airflow.providers.alibaba.cloud.hooks.base_alibaba.AccessKeyCredentials attribute)
access_key_secret (airflow.providers.alibaba.cloud.hooks.base_alibaba.AccessKeyCredentials attribute)
AccessKeyCredentials (class in airflow.providers.alibaba.cloud.hooks.base_alibaba)
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.exceptions
module
airflow.providers.alibaba.cloud.hooks
module
airflow.providers.alibaba.cloud.hooks.analyticdb_spark
module
airflow.providers.alibaba.cloud.hooks.base_alibaba
module
airflow.providers.alibaba.cloud.hooks.maxcompute
module
airflow.providers.alibaba.cloud.hooks.oss
module
airflow.providers.alibaba.cloud.links
module
airflow.providers.alibaba.cloud.links.maxcompute
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.maxcompute
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
airflow.providers.alibaba.version_compat
module
AIRFLOW_V_3_0_PLUS (in module airflow.providers.alibaba.version_compat)
aliases (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
alibaba_cloud_conn_id (airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook attribute)
AlibabaBaseHook (class in airflow.providers.alibaba.cloud.hooks.base_alibaba)
alibabacloud_conn_id (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
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
base_folder (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO property)
base_log_folder (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO attribute)
bucket_key (airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor attribute)
bucket_name (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO property)
(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
cancel_on_kill (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
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.base_alibaba.AlibabaBaseHook attribute)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook 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.base_alibaba.AlibabaBaseHook attribute)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook 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_maxcompute_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.base_alibaba.AlibabaBaseHook attribute)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook attribute)
(airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute)
default_schema (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
delete_bucket() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
delete_local_copy (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO attribute)
(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
endpoint (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook property)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
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_maxcompute_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.maxcompute.MaxComputeSQLOperator 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)
extras (airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook attribute)
F
FAILED (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)
FAILING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)
fallback_to_default_project_endpoint() (in module airflow.providers.alibaba.cloud.hooks.maxcompute)
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_access_key_credential() (airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook method)
get_adb_spark_client() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook method)
get_base_airflow_version_tuple() (in module airflow.providers.alibaba.version_compat)
get_bucket() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
get_client() (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook method)
get_conn() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
get_connection_form_widgets() (airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook class method)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook class 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_instance() (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook method)
get_link() (airflow.providers.alibaba.cloud.links.maxcompute.MaxComputeLogViewLink method)
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)
get_ui_field_behaviour() (airflow.providers.alibaba.cloud.hooks.base_alibaba.AlibabaBaseHook class method)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook class method)
H
head_key() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
hints (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
hook (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO property)
(airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator property)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
(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.base_alibaba.AlibabaBaseHook attribute)
(airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook attribute)
(airflow.providers.alibaba.cloud.hooks.oss.OSSHook attribute)
I
instance (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
io (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute)
K
key (airflow.providers.alibaba.cloud.links.maxcompute.MaxComputeLogViewLink 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)
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
maxcompute_conn_id (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook attribute)
MaxComputeConfigurationException
MaxComputeHook (class in airflow.providers.alibaba.cloud.hooks.maxcompute)
MaxComputeLogViewLink (class in airflow.providers.alibaba.cloud.links.maxcompute)
MaxComputeSQLOperator (class in airflow.providers.alibaba.cloud.operators.maxcompute)
module
airflow.providers.alibaba
airflow.providers.alibaba.cloud
airflow.providers.alibaba.cloud.exceptions
airflow.providers.alibaba.cloud.hooks
airflow.providers.alibaba.cloud.hooks.analyticdb_spark
airflow.providers.alibaba.cloud.hooks.base_alibaba
airflow.providers.alibaba.cloud.hooks.maxcompute
airflow.providers.alibaba.cloud.hooks.oss
airflow.providers.alibaba.cloud.links
airflow.providers.alibaba.cloud.links.maxcompute
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.maxcompute
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
airflow.providers.alibaba.version_compat
tests.system.alibaba
tests.system.alibaba.example_adb_spark_batch
tests.system.alibaba.example_adb_spark_sql
tests.system.alibaba.example_maxcompute_sql
tests.system.alibaba.example_oss_bucket
tests.system.alibaba.example_oss_object
monitor_application() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method)
N
name (airflow.providers.alibaba.cloud.links.maxcompute.MaxComputeLogViewLink attribute)
O
object_exists() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
on_kill() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator method)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator method)
operator_extra_links (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
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.OSSRemoteLogIO method)
oss_read() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO method)
oss_write() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO 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)
OSSRemoteLogIO (class in airflow.providers.alibaba.cloud.log.oss_task_handler)
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)
persist() (airflow.providers.alibaba.cloud.links.maxcompute.MaxComputeLogViewLink 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)
priority (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
processors (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO attribute)
project (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook property)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
provide_bucket_name() (in module airflow.providers.alibaba.cloud.hooks.oss)
Q
quota_name (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
R
read() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO method)
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)
remote_base (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO attribute)
RT (in module airflow.providers.alibaba.cloud.hooks.maxcompute)
run_sql (in module tests.system.alibaba.example_maxcompute_sql)
run_sql() (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook method)
RUNNING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)
running_cluster (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator 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)
sql (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
SQL (in module tests.system.alibaba.example_maxcompute_sql)
STARTING (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState attribute)
stop_instance() (airflow.providers.alibaba.cloud.hooks.maxcompute.MaxComputeHook method)
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_ext (airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator attribute)
template_fields (airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator attribute)
(airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator attribute)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator 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)
(airflow.providers.alibaba.cloud.operators.maxcompute.MaxComputeSQLOperator 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_maxcompute_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_maxcompute_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() (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSRemoteLogIO method)
upload_local_file() (airflow.providers.alibaba.cloud.hooks.oss.OSSHook method)
upload_on_close (airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler attribute)
Previous
Next
Was this entry helpful?
Suggest a change on this page