Airflow
latest
Project
License
Quick Start
Installation
Tutorial
How-to Guides
UI / Screenshots
Concepts
Data Profiling
Command Line Interface
Scheduling & Triggers
Plugins
Security
Time zones
Experimental Rest API
Integration
Metrics
Lineage
FAQ
API Reference
Airflow
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
X
A
acknowledge() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
add_task() (airflow.models.DAG method)
add_tasks() (airflow.models.DAG method)
aggregate() (airflow.contrib.hooks.mongo_hook.MongoHook method)
airflow.hooks.hive_hooks (module)
airflow.macros (module)
airflow.models (module)
allocate_ids() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
are_dependencies_met() (airflow.models.TaskInstance method)
are_dependents_done() (airflow.models.TaskInstance method)
AthenaSensor (class in airflow.contrib.sensors.aws_athena_sensor)
await() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)
AWSAthenaHook (class in airflow.contrib.hooks.aws_athena_hook)
AWSAthenaOperator (class in airflow.contrib.operators.aws_athena_operator)
AWSBatchOperator (class in airflow.contrib.operators.awsbatch_operator)
,
[1]
AwsDynamoDBHook (class in airflow.contrib.hooks.aws_dynamodb_hook)
,
[1]
AwsFirehoseHook (class in airflow.contrib.hooks.aws_firehose_hook)
,
[1]
AwsGlueCatalogHook (class in airflow.contrib.hooks.aws_glue_catalog_hook)
AwsGlueCatalogPartitionSensor (class in airflow.contrib.sensors.aws_glue_catalog_partition_sensor)
AwsHook (class in airflow.contrib.hooks.aws_hook)
AwsLambdaHook (class in airflow.contrib.hooks.aws_lambda_hook)
,
[1]
AwsRedshiftClusterSensor (class in airflow.contrib.sensors.aws_redshift_cluster_sensor)
,
[1]
AwsSnsHook (class in airflow.contrib.hooks.aws_sns_hook)
B
bag_dag() (airflow.models.DagBag method)
BaseOperator (class in airflow.models)
,
[1]
BaseSensorOperator (class in airflow.sensors.base_sensor_operator)
BashOperator (class in airflow.operators.bash_operator)
BashSensor (class in airflow.contrib.sensors.bash_sensor)
begin_transaction() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
BigQueryCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)
,
[1]
BigQueryCreateEmptyDatasetOperator (class in airflow.contrib.operators.bigquery_operator)
,
[1]
BigQueryCreateEmptyTableOperator (class in airflow.contrib.operators.bigquery_operator)
,
[1]
BigQueryCreateExternalTableOperator (class in airflow.contrib.operators.bigquery_operator)
,
[1]
BigQueryDeleteDatasetOperator (class in airflow.contrib.operators.bigquery_operator)
,
[1]
BigQueryGetDataOperator (class in airflow.contrib.operators.bigquery_get_data)
,
[1]
BigQueryHook (class in airflow.contrib.hooks.bigquery_hook)
,
[1]
BigQueryIntervalCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)
,
[1]
BigQueryOperator (class in airflow.contrib.operators.bigquery_operator)
,
[1]
BigQueryTableDeleteOperator (class in airflow.contrib.operators.bigquery_table_delete_operator)
,
[1]
BigQueryTableSensor (class in airflow.contrib.sensors.bigquery_sensor)
BigQueryToBigQueryOperator (class in airflow.contrib.operators.bigquery_to_bigquery)
,
[1]
BigQueryToCloudStorageOperator (class in airflow.contrib.operators.bigquery_to_gcs)
,
[1]
BigQueryValueCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)
,
[1]
BranchPythonOperator (class in airflow.operators.python_operator)
bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.mysql_hook.MySqlHook method)
(airflow.hooks.postgres_hook.PostgresHook method)
bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.mysql_hook.MySqlHook method)
(airflow.hooks.postgres_hook.PostgresHook method)
C
CassandraHook (class in airflow.contrib.hooks.cassandra_hook)
CassandraRecordSensor (class in airflow.contrib.sensors.cassandra_record_sensor)
CassandraTableSensor (class in airflow.contrib.sensors.cassandra_table_sensor)
CassandraToGoogleCloudStorageOperator (class in airflow.contrib.operators.cassandra_to_gcs)
Chart (class in airflow.models)
check_for_bucket() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
check_for_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
check_for_named_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
check_for_partition() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)
(airflow.hooks.hive_hooks.HiveMetastoreHook method)
check_for_prefix() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
check_for_wildcard_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
check_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
check_response() (airflow.hooks.http_hook.HttpHook method)
check_s3_url() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
check_status() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
check_training_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
check_training_status_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
check_tuning_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
CheckOperator (class in airflow.operators.check_operator)
cleanup_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
clear() (airflow.models.BaseOperator method)
,
[1]
(airflow.models.DAG method)
clear_task_instances() (in module airflow.models)
clear_xcom_data() (airflow.models.TaskInstance method)
cli() (airflow.models.DAG method)
close_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
closest_ds_partition() (in module airflow.macros.hive)
CloudantHook (class in airflow.contrib.hooks.cloudant_hook)
CloudSqlDatabaseHook (class in airflow.contrib.hooks.gcp_sql_hook)
CloudSqlHook (class in airflow.contrib.hooks.gcp_sql_hook)
CloudSqlInstanceCreateOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceDatabaseCreateOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceDatabaseDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceDatabasePatchOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceExportOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstanceImportOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlInstancePatchOperator (class in airflow.contrib.operators.gcp_sql_operator)
CloudSqlProxyRunner (class in airflow.contrib.hooks.gcp_sql_hook)
CloudSqlQueryOperator (class in airflow.contrib.operators.gcp_sql_operator)
cluster_status() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)
,
[1]
collect_dags() (airflow.models.DagBag method)
command() (airflow.models.TaskInstance method)
command_as_list() (airflow.models.TaskInstance method)
commit() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
concurrency_reached (airflow.models.DAG attribute)
configure_s3_resources() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
construct_api_call_params() (airflow.operators.slack_operator.SlackAPIOperator method)
(airflow.operators.slack_operator.SlackAPIPostOperator method)
construct_ingest_query() (airflow.operators.hive_to_druid.HiveToDruidTransfer method)
convert_map_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)
convert_tuple_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)
convert_types() (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method)
convert_user_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)
copy() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
copy_expert() (airflow.hooks.postgres_hook.PostgresHook method)
copy_object() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
create_bucket() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
(airflow.hooks.S3_hook.S3Hook method)
,
[1]
create_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)
,
[1]
create_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
create_dagrun() (airflow.models.DAG method)
(airflow.models.DagModel method)
create_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
create_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
create_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
create_job() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
create_job_flow() (airflow.contrib.hooks.emr_hook.EmrHook method)
,
[1]
create_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
(airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_new_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)
create_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
create_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
create_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
create_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
current_state() (airflow.models.TaskInstance method)
D
dag (airflow.models.BaseOperator attribute)
,
[1]
DAG (class in airflow.models)
DagBag (class in airflow.models)
dagbag_report() (airflow.models.DagBag method)
DagModel (class in airflow.models)
DagRun (class in airflow.models)
DatabricksHook (class in airflow.contrib.hooks.databricks_hook)
DatabricksSubmitRunOperator (class in airflow.contrib.operators.databricks_operator)
,
[1]
DataFlowHook (class in airflow.contrib.hooks.gcp_dataflow_hook)
,
[1]
DataFlowJavaOperator (class in airflow.contrib.operators.dataflow_operator)
,
[1]
DataFlowPythonOperator (class in airflow.contrib.operators.dataflow_operator)
,
[1]
DataflowTemplateOperator (class in airflow.contrib.operators.dataflow_operator)
,
[1]
DataprocClusterCreateOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataprocClusterDeleteOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataprocClusterScaleOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcHadoopOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcHiveOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcHook (class in airflow.contrib.hooks.gcp_dataproc_hook)
DataProcPigOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcPySparkOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcSparkOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataProcSparkSqlOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataprocWorkflowTemplateBaseOperator (class in airflow.contrib.operators.dataproc_operator)
DataprocWorkflowTemplateInstantiateInlineOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DataprocWorkflowTemplateInstantiateOperator (class in airflow.contrib.operators.dataproc_operator)
,
[1]
DatastoreExportOperator (class in airflow.contrib.operators.datastore_export_operator)
,
[1]
DatastoreHook (class in airflow.contrib.hooks.datastore_hook)
,
[1]
DatastoreImportOperator (class in airflow.contrib.operators.datastore_import_operator)
,
[1]
DayOfWeekSensor (class in airflow.contrib.sensors.weekday_sensor)
db() (airflow.contrib.hooks.cloudant_hook.CloudantHook method)
DbApiHook (class in airflow.hooks.dbapi_hook)
deactivate_stale_dags() (airflow.models.DAG static method)
deactivate_unknown_dags() (airflow.models.DAG static method)
delete() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
delete_cluster() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)
,
[1]
delete_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
delete_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
delete_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
delete_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)
delete_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
delete_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)
delete_objects() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
delete_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)
delete_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
delete_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
delete_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
delete_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
deps (airflow.models.BaseOperator attribute)
,
[1]
(airflow.sensors.base_sensor_operator.BaseSensorOperator attribute)
describe_cluster_snapshots() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)
,
[1]
describe_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
describe_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_model() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_object() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
describe_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_training_job_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
describe_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
DiscordWebhookHook (class in airflow.contrib.hooks.discord_webhook_hook)
DiscordWebhookOperator (class in airflow.contrib.operators.discord_webhook_operator)
DockerHook (class in airflow.hooks.docker_hook)
DockerOperator (class in airflow.operators.docker_operator)
download() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
download_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method)
downstream_list (airflow.models.BaseOperator attribute)
,
[1]
DruidCheckOperator (class in airflow.operators.druid_check_operator)
DruidDbApiHook (class in airflow.hooks.druid_hook)
DruidHook (class in airflow.hooks.druid_hook)
DruidOperator (class in airflow.contrib.operators.druid_operator)
ds_add() (in module airflow.macros)
ds_format() (in module airflow.macros)
DummyOperator (class in airflow.operators.dummy_operator)
E
ECSOperator (class in airflow.contrib.operators.ecs_operator)
,
[1]
EmailOperator (class in airflow.operators.email_operator)
EmrAddStepsOperator (class in airflow.contrib.operators.emr_add_steps_operator)
,
[1]
EmrBaseSensor (class in airflow.contrib.sensors.emr_base_sensor)
EmrCreateJobFlowOperator (class in airflow.contrib.operators.emr_create_job_flow_operator)
,
[1]
EmrHook (class in airflow.contrib.hooks.emr_hook)
,
[1]
EmrJobFlowSensor (class in airflow.contrib.sensors.emr_job_flow_sensor)
EmrStepSensor (class in airflow.contrib.sensors.emr_step_sensor)
EmrTerminateJobFlowOperator (class in airflow.contrib.operators.emr_terminate_job_flow_operator)
,
[1]
end() (airflow.executors.local_executor.LocalExecutor method)
(airflow.executors.sequential_executor.SequentialExecutor method)
error() (airflow.models.TaskInstance method)
execute() (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method)
(airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method)
(airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method)
(airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator method)
,
[1]
(airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator method)
(airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator method)
,
[1]
(airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method)
(airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator method)
(airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator method)
(airflow.contrib.operators.spark_sql_operator.SparkSqlOperator method)
(airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator method)
(airflow.contrib.operators.sqoop_operator.SqoopOperator method)
(airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method)
(airflow.models.BaseOperator method)
,
[1]
(airflow.operators.bash_operator.BashOperator method)
(airflow.operators.slack_operator.SlackAPIOperator method)
execute_async() (airflow.executors.local_executor.LocalExecutor method)
(airflow.executors.sequential_executor.SequentialExecutor method)
exists() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
expand_role() (airflow.contrib.hooks.aws_hook.AwsHook method)
export_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
export_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)
export_to_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
ExternalTaskSensor (class in airflow.sensors.external_task_sensor)
F
fallback_to_default_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method)
,
[1]
filepath (airflow.models.DAG attribute)
FileSensor (class in airflow.contrib.sensors.file_sensor)
FileToGoogleCloudStorageOperator (class in airflow.contrib.operators.file_to_gcs)
,
[1]
filter_for_filesize() (airflow.sensors.hdfs_sensor.HdfsSensor static method)
filter_for_ignored_ext() (airflow.sensors.hdfs_sensor.HdfsSensor static method)
find() (airflow.contrib.hooks.mongo_hook.MongoHook method)
(airflow.models.DagRun static method)
find_for_task_instance() (airflow.models.TaskReschedule static method)
folder (airflow.models.DAG attribute)
following_schedule() (airflow.models.DAG method)
free_reserved_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
FSHook (class in airflow.contrib.hooks.fs_hook)
FTPHook (class in airflow.contrib.hooks.ftp_hook)
FTPSensor (class in airflow.contrib.sensors.ftp_sensor)
FTPSHook (class in airflow.contrib.hooks.ftp_hook)
FTPSSensor (class in airflow.contrib.sensors.ftp_sensor)
G
GceBaseOperator (class in airflow.contrib.operators.gcp_compute_operator)
GceHook (class in airflow.contrib.hooks.gcp_compute_hook)
GceInstanceGroupManagerUpdateTemplateOperator (class in airflow.contrib.operators.gcp_compute_operator)
GceInstanceStartOperator (class in airflow.contrib.operators.gcp_compute_operator)
GceInstanceStopOperator (class in airflow.contrib.operators.gcp_compute_operator)
GceInstanceTemplateCopyOperator (class in airflow.contrib.operators.gcp_compute_operator)
GceSetMachineTypeOperator (class in airflow.contrib.operators.gcp_compute_operator)
GcfFunctionDeleteOperator (class in airflow.contrib.operators.gcp_function_operator)
GcfFunctionDeployOperator (class in airflow.contrib.operators.gcp_function_operator)
GcfHook (class in airflow.contrib.hooks.gcp_function_hook)
GCPTransferServiceHook (class in airflow.contrib.hooks.gcp_transfer_hook)
,
[1]
generate_command() (airflow.models.TaskInstance static method)
GenericTransfer (class in airflow.operators.generic_transfer)
get_active_runs() (airflow.models.DAG method)
get_autocommit() (airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.mssql_hook.MsSqlHook method)
(airflow.hooks.mysql_hook.MySqlHook method)
get_available_fields() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
get_bucket() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method)
get_conn() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
(airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method)
,
[1]
(airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)
(airflow.contrib.hooks.aws_sns_hook.AwsSnsHook method)
(airflow.contrib.hooks.bigquery_hook.BigQueryHook method)
,
[1]
(airflow.contrib.hooks.cassandra_hook.CassandraHook method)
(airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
(airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.ftp_hook.FTPSHook method)
(airflow.contrib.hooks.gcp_compute_hook.GceHook method)
(airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method)
,
[1]
(airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)
(airflow.contrib.hooks.gcp_function_hook.GcfHook method)
(airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
(airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
(airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
(airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method)
,
[1]
(airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
(airflow.contrib.hooks.mongo_hook.MongoHook method)
(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
(airflow.contrib.hooks.ssh_hook.SSHHook method)
(airflow.contrib.hooks.vertica_hook.VerticaHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.druid_hook.DruidDbApiHook method)
(airflow.hooks.hdfs_hook.HDFSHook method)
(airflow.hooks.http_hook.HttpHook method)
(airflow.hooks.mssql_hook.MsSqlHook method)
(airflow.hooks.mysql_hook.MySqlHook method)
(airflow.hooks.postgres_hook.PostgresHook method)
(airflow.hooks.presto_hook.PrestoHook method)
(airflow.hooks.sqlite_hook.SqliteHook method)
get_context_from_env_var() (in module airflow.hooks.hive_hooks)
get_crc32c() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
get_credentials() (airflow.contrib.hooks.aws_hook.AwsHook method)
get_cursor() (airflow.hooks.dbapi_hook.DbApiHook method)
get_dag() (airflow.models.DagBag method)
(airflow.models.DagRun method)
get_dagrun() (airflow.models.DAG method)
(airflow.models.TaskInstance method)
get_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
get_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
get_databases() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
get_db_hook() (airflow.operators.druid_check_operator.DruidCheckOperator method)
get_default_view() (airflow.models.DAG method)
get_direct_relative_ids() (airflow.models.BaseOperator method)
,
[1]
get_direct_relatives() (airflow.models.BaseOperator method)
,
[1]
get_fernet() (in module airflow.models)
get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.presto_hook.PrestoHook method)
(airflow.operators.druid_check_operator.DruidCheckOperator method)
get_flat_relative_ids() (airflow.models.BaseOperator method)
,
[1]
get_flat_relatives() (airflow.models.BaseOperator method)
,
[1]
get_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)
get_hook() (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method)
get_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
get_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
get_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
get_jobs_id() (airflow.contrib.hooks.qubole_hook.QuboleHook method)
get_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
get_last_dagrun() (in module airflow.models)
get_latest_runs() (airflow.models.DagRun class method)
get_log() (airflow.contrib.hooks.qubole_hook.QuboleHook method)
get_log_conn() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
get_many() (airflow.models.XCom class method)
get_md5hash() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
get_metastore_client() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
get_mod_time() (airflow.contrib.hooks.ftp_hook.FTPHook method)
get_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
get_num_active_runs() (airflow.models.DAG method)
get_num_task_instances() (airflow.models.DAG static method)
get_object_from_salesforce() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
get_one() (airflow.models.XCom class method)
get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
get_pandas_df() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)
,
[1]
(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.druid_hook.DruidDbApiHook method)
(airflow.hooks.hive_hooks.HiveServer2Hook method)
(airflow.hooks.presto_hook.PrestoHook method)
get_partitions() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)
(airflow.hooks.hive_hooks.HiveMetastoreHook method)
get_previous_dagrun() (airflow.models.DagRun method)
get_previous_scheduled_dagrun() (airflow.models.DagRun method)
get_proxy_version() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)
get_query_results() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
get_records() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.hive_hooks.HiveServer2Hook method)
(airflow.hooks.presto_hook.PrestoHook method)
get_results() (airflow.contrib.hooks.qubole_hook.QuboleHook method)
(airflow.hooks.hive_hooks.HiveServer2Hook method)
get_run() (airflow.models.DagRun static method)
get_run_dates() (airflow.models.DAG method)
get_service() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)
,
[1]
get_session() (airflow.contrib.hooks.aws_hook.AwsHook method)
get_size() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
get_socket_path() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)
get_sqlproxy_runner() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
get_table() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
get_tables() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
get_task_instance() (airflow.models.DagRun method)
get_task_instances() (airflow.models.BaseOperator method)
,
[1]
(airflow.models.DagRun method)
get_template_env() (airflow.models.DAG method)
get_tunnel() (airflow.contrib.hooks.ssh_hook.SSHHook method)
get_uri() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.druid_hook.DruidDbApiHook method)
get_wildcard_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook)
,
[1]
GoogleCloudStorageBucketCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator)
GoogleCloudStorageCreateBucketOperator (class in airflow.contrib.operators.gcs_operator)
,
[1]
GoogleCloudStorageDownloadOperator (class in airflow.contrib.operators.gcs_download_operator)
,
[1]
GoogleCloudStorageHook (class in airflow.contrib.hooks.gcs_hook)
,
[1]
GoogleCloudStorageListOperator (class in airflow.contrib.operators.gcs_list_operator)
,
[1]
GoogleCloudStorageObjectCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator)
GoogleCloudStorageObjectSensor (class in airflow.contrib.sensors.gcs_sensor)
GoogleCloudStorageObjectUpdatedSensor (class in airflow.contrib.sensors.gcs_sensor)
GoogleCloudStoragePrefixSensor (class in airflow.contrib.sensors.gcs_sensor)
GoogleCloudStorageToBigQueryOperator (class in airflow.contrib.operators.gcs_to_bq)
,
[1]
GoogleCloudStorageToGoogleCloudStorageOperator (class in airflow.contrib.operators.gcs_to_gcs)
,
[1]
GoogleCloudStorageToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.gcs_to_gcs_transfer_operator)
,
[1]
GoogleCloudStorageToS3Operator (class in airflow.contrib.operators.gcs_to_s3)
H
handle_callback() (airflow.models.DAG method)
has_dag() (airflow.models.BaseOperator method)
,
[1]
has_mail_attachment() (airflow.contrib.hooks.imap_hook.ImapHook method)
HDFSHook (class in airflow.hooks.hdfs_hook)
HdfsSensor (class in airflow.sensors.hdfs_sensor)
HdfsSensorFolder (class in airflow.contrib.sensors.hdfs_sensor)
HdfsSensorRegex (class in airflow.contrib.sensors.hdfs_sensor)
HipChatAPIOperator (class in airflow.contrib.operators.hipchat_operator)
HipChatAPISendRoomNotificationOperator (class in airflow.contrib.operators.hipchat_operator)
HiveCliHook (class in airflow.hooks.hive_hooks)
HiveMetastoreHook (class in airflow.hooks.hive_hooks)
HiveOperator (class in airflow.operators.hive_operator)
HivePartitionSensor (class in airflow.sensors.hive_partition_sensor)
HiveServer2Hook (class in airflow.hooks.hive_hooks)
HiveStatsCollectionOperator (class in airflow.operators.hive_stats_operator)
HiveToDruidTransfer (class in airflow.operators.hive_to_druid)
HiveToDynamoDBTransferOperator (class in airflow.contrib.operators.hive_to_dynamodb)
,
[1]
HiveToMySqlTransfer (class in airflow.operators.hive_to_mysql)
HttpHook (class in airflow.hooks.http_hook)
HttpSensor (class in airflow.sensors.http_sensor)
I
ImapAttachmentSensor (class in airflow.contrib.sensors.imap_attachment_sensor)
ImapHook (class in airflow.contrib.hooks.imap_hook)
import_from_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
import_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
import_query() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)
import_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)
init_on_load() (airflow.models.TaskInstance method)
init_run_context() (airflow.models.TaskInstance method)
insert_bucket_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
insert_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
insert_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)
insert_object_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
insert_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)
insert_rows() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)
,
[1]
(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.druid_hook.DruidDbApiHook method)
(airflow.hooks.presto_hook.PrestoHook method)
IntervalCheckOperator (class in airflow.operators.check_operator)
InvalidFernetToken
invoke_lambda() (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method)
,
[1]
is_eligible_to_retry() (airflow.models.TaskInstance method)
is_fixed_time_schedule() (airflow.models.DAG method)
is_paused (airflow.models.DAG attribute)
is_premature (airflow.models.TaskInstance attribute)
is_updated_after() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
K
key (airflow.models.TaskInstance attribute)
kill() (airflow.contrib.hooks.qubole_hook.QuboleHook method)
kill_zombies() (airflow.models.DagBag method)
KubeResourceVersion (class in airflow.models)
KubeWorkerIdentifier (class in airflow.models)
L
latest_execution_date (airflow.models.DAG attribute)
LatestOnlyOperator (class in airflow.operators.latest_only_operator)
list() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
list_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
list_keys() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
list_prefixes() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
list_versions() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
load_bytes() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
load_df() (airflow.hooks.hive_hooks.HiveCliHook method)
load_file() (airflow.hooks.hive_hooks.HiveCliHook method)
(airflow.hooks.S3_hook.S3Hook method)
,
[1]
load_file_obj() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
load_string() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
LocalExecutor (class in airflow.executors.local_executor)
Log (class in airflow.models)
log_stream() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
lookup() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
M
make_query() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
max_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)
(in module airflow.macros.hive)
MetastorePartitionSensor (class in airflow.sensors.metastore_partition_sensor)
MLEngineBatchPredictionOperator (class in airflow.contrib.operators.mlengine_operator)
,
[1]
MLEngineHook (class in airflow.contrib.hooks.gcp_mlengine_hook)
,
[1]
MLEngineModelOperator (class in airflow.contrib.operators.mlengine_operator)
,
[1]
MLEngineTrainingOperator (class in airflow.contrib.operators.mlengine_operator)
,
[1]
MLEngineVersionOperator (class in airflow.contrib.operators.mlengine_operator)
,
[1]
MongoHook (class in airflow.contrib.hooks.mongo_hook)
MongoToS3Operator (class in airflow.contrib.operators.mongo_to_s3)
MsSqlHook (class in airflow.hooks.mssql_hook)
MsSqlOperator (class in airflow.operators.mssql_operator)
MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive)
multi_stream_iter() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
MySqlHook (class in airflow.hooks.mysql_hook)
MySqlOperator (class in airflow.operators.mysql_operator)
MySqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mysql_to_gcs)
,
[1]
MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)
N
NamedHivePartitionSensor (class in airflow.sensors.named_hive_partition_sensor)
next_retry_datetime() (airflow.models.TaskInstance method)
normalize_schedule() (airflow.models.DAG method)
NullFernet (class in airflow.models)
O
on_kill() (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method)
(airflow.models.BaseOperator method)
,
[1]
open_slots() (airflow.models.Pool method)
OpenFaasHook (class in airflow.contrib.hooks.openfaas_hook)
P
patch_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
patch_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)
patch_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
PigCliHook (class in airflow.hooks.pig_hook)
PigOperator (class in airflow.operators.pig_operator)
PinotDbApiHook (class in airflow.contrib.hooks.pinot_hook)
poke() (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor method)
(airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method)
(airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor method)
,
[1]
(airflow.contrib.sensors.bash_sensor.BashSensor method)
(airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor method)
(airflow.contrib.sensors.cassandra_record_sensor.CassandraRecordSensor method)
(airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor method)
(airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor method)
(airflow.contrib.sensors.file_sensor.FileSensor method)
(airflow.contrib.sensors.ftp_sensor.FTPSensor method)
(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor method)
(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor method)
(airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor method)
(airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder method)
(airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex method)
(airflow.contrib.sensors.imap_attachment_sensor.ImapAttachmentSensor method)
(airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method)
(airflow.contrib.sensors.python_sensor.PythonSensor method)
(airflow.contrib.sensors.qubole_sensor.QuboleSensor method)
(airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor method)
(airflow.contrib.sensors.sftp_sensor.SFTPSensor method)
(airflow.contrib.sensors.weekday_sensor.DayOfWeekSensor method)
(airflow.sensors.base_sensor_operator.BaseSensorOperator method)
(airflow.sensors.external_task_sensor.ExternalTaskSensor method)
(airflow.sensors.hdfs_sensor.HdfsSensor method)
(airflow.sensors.hive_partition_sensor.HivePartitionSensor method)
(airflow.sensors.http_sensor.HttpSensor method)
(airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor method)
(airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor method)
(airflow.sensors.s3_key_sensor.S3KeySensor method)
(airflow.sensors.s3_prefix_sensor.S3PrefixSensor method)
(airflow.sensors.sql_sensor.SqlSensor method)
(airflow.sensors.time_delta_sensor.TimeDeltaSensor method)
(airflow.sensors.time_sensor.TimeSensor method)
(airflow.sensors.web_hdfs_sensor.WebHdfsSensor method)
poll_operation_until_done() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
poll_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
Pool (class in airflow.models)
pool_full() (airflow.models.TaskInstance method)
Popen() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)
post_execute() (airflow.models.BaseOperator method)
,
[1]
PostgresHook (class in airflow.hooks.postgres_hook)
PostgresOperator (class in airflow.operators.postgres_operator)
PostgresToGoogleCloudStorageOperator (class in airflow.contrib.operators.postgres_to_gcs_operator)
pre_execute() (airflow.models.BaseOperator method)
,
[1]
prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method)
(airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator method)
prepare_template() (airflow.models.BaseOperator method)
,
[1]
PrestoCheckOperator (class in airflow.operators.presto_check_operator)
PrestoHook (class in airflow.hooks.presto_hook)
PrestoIntervalCheckOperator (class in airflow.operators.presto_check_operator)
PrestoToMySqlTransfer (class in airflow.operators.presto_to_mysql)
PrestoValueCheckOperator (class in airflow.operators.presto_check_operator)
previous_schedule() (airflow.models.DAG method)
previous_ti (airflow.models.TaskInstance attribute)
process_file() (airflow.models.DagBag method)
publish() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
publish_to_target() (airflow.contrib.hooks.aws_sns_hook.AwsSnsHook method)
PubSubHook (class in airflow.contrib.hooks.gcp_pubsub_hook)
PubSubPublishOperator (class in airflow.contrib.operators.pubsub_operator)
PubSubPullSensor (class in airflow.contrib.sensors.pubsub_sensor)
PubSubSubscriptionCreateOperator (class in airflow.contrib.operators.pubsub_operator)
PubSubSubscriptionDeleteOperator (class in airflow.contrib.operators.pubsub_operator)
PubSubTopicCreateOperator (class in airflow.contrib.operators.pubsub_operator)
PubSubTopicDeleteOperator (class in airflow.contrib.operators.pubsub_operator)
pull() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)
put_records() (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method)
,
[1]
PythonOperator (class in airflow.operators.python_operator)
PythonSensor (class in airflow.contrib.sensors.python_sensor)
PythonVirtualenvOperator (class in airflow.operators.python_operator)
Q
QuboleCheckOperator (class in airflow.contrib.operators.qubole_check_operator)
,
[1]
QuboleFileSensor (class in airflow.contrib.sensors.qubole_sensor)
QuboleHook (class in airflow.contrib.hooks.qubole_hook)
QuboleOperator (class in airflow.contrib.operators.qubole_operator)
,
[1]
QubolePartitionSensor (class in airflow.contrib.sensors.qubole_sensor)
QuboleSensor (class in airflow.contrib.sensors.qubole_sensor)
QuboleValueCheckOperator (class in airflow.contrib.operators.qubole_check_operator)
,
[1]
queued_slots() (airflow.models.Pool method)
R
random() (in module airflow.macros)
read_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
ready_for_retry() (airflow.models.TaskInstance method)
record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)
RedshiftHook (class in airflow.contrib.hooks.redshift_hook)
,
[1]
RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator)
,
[1]
refresh_from_db() (airflow.models.DagRun method)
(airflow.models.TaskInstance method)
rename() (airflow.contrib.hooks.ftp_hook.FTPHook method)
render_template() (airflow.models.BaseOperator method)
,
[1]
render_template_from_field() (airflow.models.BaseOperator method)
,
[1]
replace_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)
replace_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)
reserve_free_tcp_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
restore_from_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)
,
[1]
retrieve_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)
retrieve_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
retrieve_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method)
rewrite() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
rollback() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
run() (airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.http_hook.HttpHook method)
(airflow.hooks.presto_hook.PrestoHook method)
(airflow.models.BaseOperator method)
,
[1]
(airflow.models.DAG method)
run_and_check() (airflow.hooks.http_hook.HttpHook method)
run_cli() (airflow.hooks.hive_hooks.HiveCliHook method)
(airflow.hooks.pig_hook.PigCliHook method)
run_now() (airflow.contrib.hooks.databricks_hook.DatabricksHook method)
run_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
(airflow.contrib.hooks.datastore_hook.DatastoreHook method)
,
[1]
(airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method)
run_with_advanced_retry() (airflow.hooks.http_hook.HttpHook method)
S
S3CopyObjectOperator (class in airflow.contrib.operators.s3_copy_object_operator)
S3DeleteObjectsOperator (class in airflow.contrib.operators.s3_delete_objects_operator)
S3FileTransformOperator (class in airflow.operators.s3_file_transform_operator)
,
[1]
S3Hook (class in airflow.hooks.S3_hook)
,
[1]
S3KeySensor (class in airflow.sensors.s3_key_sensor)
S3ListOperator (class in airflow.contrib.operators.s3_list_operator)
,
[1]
S3PrefixSensor (class in airflow.sensors.s3_prefix_sensor)
S3ToGoogleCloudStorageOperator (class in airflow.contrib.operators.s3_to_gcs_operator)
,
[1]
S3ToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.s3_to_gcs_transfer_operator)
S3ToHiveTransfer (class in airflow.operators.s3_to_hive_operator)
,
[1]
S3ToRedshiftTransfer (class in airflow.operators.s3_to_redshift_operator)
,
[1]
SageMakerBaseOperator (class in airflow.contrib.operators.sagemaker_base_operator)
SageMakerBaseSensor (class in airflow.contrib.sensors.sagemaker_base_sensor)
SageMakerEndpointConfigOperator (class in airflow.contrib.operators.sagemaker_endpoint_config_operator)
,
[1]
SageMakerEndpointOperator (class in airflow.contrib.operators.sagemaker_endpoint_operator)
,
[1]
SageMakerEndpointSensor (class in airflow.contrib.sensors.sagemaker_endpoint_sensor)
SageMakerHook (class in airflow.contrib.hooks.sagemaker_hook)
,
[1]
SageMakerModelOperator (class in airflow.contrib.operators.sagemaker_model_operator)
,
[1]
SageMakerTrainingOperator (class in airflow.contrib.operators.sagemaker_training_operator)
,
[1]
SageMakerTrainingSensor (class in airflow.contrib.sensors.sagemaker_training_sensor)
SageMakerTransformOperator (class in airflow.contrib.operators.sagemaker_transform_operator)
,
[1]
SageMakerTransformSensor (class in airflow.contrib.sensors.sagemaker_transform_sensor)
SageMakerTuningOperator (class in airflow.contrib.operators.sagemaker_tuning_operator)
,
[1]
SageMakerTuningSensor (class in airflow.contrib.sensors.sagemaker_tuning_sensor)
SalesforceHook (class in airflow.contrib.hooks.salesforce_hook)
schedule_interval (airflow.models.BaseOperator attribute)
,
[1]
Secret (class in airflow.contrib.kubernetes.secret)
select_key() (airflow.hooks.S3_hook.S3Hook method)
,
[1]
SequentialExecutor (class in airflow.executors.sequential_executor)
set() (airflow.models.XCom class method)
set_autocommit() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)
(airflow.hooks.dbapi_hook.DbApiHook method)
(airflow.hooks.druid_hook.DruidDbApiHook method)
(airflow.hooks.mssql_hook.MsSqlHook method)
(airflow.hooks.mysql_hook.MySqlHook method)
set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)
,
[1]
set_dependency() (airflow.models.DAG method)
set_downstream() (airflow.models.BaseOperator method)
,
[1]
set_machine_type() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
set_upstream() (airflow.models.BaseOperator method)
,
[1]
setdefault() (airflow.models.Variable class method)
SFTPHook (class in airflow.contrib.hooks.sftp_hook)
SFTPOperator (class in airflow.contrib.operators.sftp_operator)
SFTPSensor (class in airflow.contrib.sensors.sftp_sensor)
ShortCircuitOperator (class in airflow.operators.python_operator)
shutdown_cluster() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)
sign_in() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
SimpleHttpOperator (class in airflow.operators.http_operator)
size() (airflow.models.DagBag method)
SlackAPIOperator (class in airflow.operators.slack_operator)
SlackAPIPostOperator (class in airflow.operators.slack_operator)
SlackHook (class in airflow.hooks.slack_hook)
SlackWebhookHook (class in airflow.contrib.hooks.slack_webhook_hook)
SlackWebhookOperator (class in airflow.contrib.operators.slack_webhook_operator)
SlaMiss (class in airflow.models)
SnsPublishOperator (class in airflow.contrib.operators.sns_publish_operator)
SparkJDBCHook (class in airflow.contrib.hooks.spark_jdbc_hook)
SparkJDBCOperator (class in airflow.contrib.operators.spark_jdbc_operator)
SparkSqlHook (class in airflow.contrib.hooks.spark_sql_hook)
SparkSqlOperator (class in airflow.contrib.operators.spark_sql_operator)
SparkSubmitHook (class in airflow.contrib.hooks.spark_submit_hook)
SparkSubmitOperator (class in airflow.contrib.operators.spark_submit_operator)
SqliteHook (class in airflow.hooks.sqlite_hook)
SqliteOperator (class in airflow.operators.sqlite_operator)
SqlSensor (class in airflow.sensors.sql_sensor)
SqoopHook (class in airflow.contrib.hooks.sqoop_hook)
SqoopOperator (class in airflow.contrib.operators.sqoop_operator)
SSHHook (class in airflow.contrib.hooks.ssh_hook)
SSHOperator (class in airflow.contrib.operators.ssh_operator)
start() (airflow.executors.local_executor.LocalExecutor method)
start_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
start_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)
stop_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)
stop_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)
stop_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)
store_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)
(airflow.contrib.hooks.sftp_hook.SFTPHook method)
sub_dag() (airflow.models.DAG method)
SubDagOperator (class in airflow.operators.subdag_operator)
subdags (airflow.models.DAG attribute)
submit() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method)
submit_run() (airflow.contrib.hooks.databricks_hook.DatabricksHook method)
sync() (airflow.executors.local_executor.LocalExecutor method)
(airflow.executors.sequential_executor.SequentialExecutor method)
sync_to_db() (airflow.models.DAG method)
T
table_exists() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)
,
[1]
(airflow.contrib.hooks.cassandra_hook.CassandraHook method)
(airflow.hooks.hive_hooks.HiveMetastoreHook method)
tar_and_s3_upload() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
TaskFail (class in airflow.models)
TaskInstance (class in airflow.models)
TaskReschedule (class in airflow.models)
template_fields (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute)
test_cycle() (airflow.models.DAG method)
test_hql() (airflow.hooks.hive_hooks.HiveCliHook method)
TimeDeltaSensor (class in airflow.sensors.time_delta_sensor)
TimeSensor (class in airflow.sensors.time_sensor)
to_csv() (airflow.hooks.hive_hooks.HiveServer2Hook method)
topological_sort() (airflow.models.DAG method)
transform() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator static method)
tree_view() (airflow.models.DAG method)
TriggerDagRunOperator (class in airflow.operators.dagrun_operator)
try_number (airflow.models.TaskInstance attribute)
type_map() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator class method)
,
[1]
(airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method)
U
update_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)
,
[1]
update_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)
update_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)
update_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)
update_state() (airflow.models.DagRun method)
upload() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)
,
[1]
upload_function_zip() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)
upstream_list (airflow.models.BaseOperator attribute)
,
[1]
used_slots() (airflow.models.Pool method)
User (class in airflow.models)
V
ValueCheckOperator (class in airflow.operators.check_operator)
Variable (class in airflow.models)
verify_integrity() (airflow.models.DagRun method)
VerticaHook (class in airflow.contrib.hooks.vertica_hook)
VerticaOperator (class in airflow.contrib.operators.vertica_operator)
VerticaToHiveTransfer (class in airflow.contrib.operators.vertica_to_hive)
W
wait() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)
WebHdfsSensor (class in airflow.sensors.web_hdfs_sensor)
write_batch_data() (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method)
,
[1]
write_object_to_file() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)
X
XCom (class in airflow.models)
xcom_pull() (airflow.models.BaseOperator method)
,
[1]
(airflow.models.TaskInstance method)
xcom_push() (airflow.models.BaseOperator method)
,
[1]
(airflow.models.TaskInstance method)
Read the Docs
v: latest
Versions
latest
stable
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.