You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2018/08/29 20:24:35 UTC
[07/48] incubator-airflow-site git commit: 1.10.0 with Updated Api
Reference
http://git-wip-us.apache.org/repos/asf/incubator-airflow-site/blob/7d4d7628/genindex.html
----------------------------------------------------------------------
diff --git a/genindex.html b/genindex.html
index d9028f8..71dfe50 100644
--- a/genindex.html
+++ b/genindex.html
@@ -25,25 +25,17 @@
-
-
- <link rel="stylesheet" href="_static/css/theme.css" type="text/css" />
-
-
-
-
-
- <link rel="index" title="Index"
- href="#"/>
- <link rel="search" title="Search" href="search.html"/>
- <link rel="top" title="Airflow Documentation" href="index.html"/>
+ <link rel="stylesheet" href="_static/css/theme.css" type="text/css" />
+ <link rel="stylesheet" href="_static/pygments.css" type="text/css" />
+ <link rel="index" title="Index" href="#" />
+ <link rel="search" title="Search" href="search.html" />
<script src="_static/js/modernizr.min.js"></script>
</head>
-<body class="wy-body-for-nav" role="document">
+<body class="wy-body-for-nav">
<div class="wy-grid-for-nav">
@@ -116,7 +108,7 @@
<section data-toggle="wy-nav-shift" class="wy-nav-content-wrap">
- <nav class="wy-nav-top" role="navigation" aria-label="top navigation">
+ <nav class="wy-nav-top" aria-label="top navigation">
<i data-toggle="wy-nav-top" class="fa fa-bars"></i>
<a href="index.html">Airflow</a>
@@ -124,9 +116,10 @@
</nav>
-
<div class="wy-nav-content">
+
<div class="rst-content">
+
@@ -194,6 +187,7 @@
| <a href="#V"><strong>V</strong></a>
| <a href="#W"><strong>W</strong></a>
| <a href="#X"><strong>X</strong></a>
+ | <a href="#Z"><strong>Z</strong></a>
</div>
<h2 id="A">A</h2>
@@ -205,6 +199,10 @@
</li>
<li><a href="code.html#airflow.models.DAG.add_tasks">add_tasks() (airflow.models.DAG method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.aggregate">aggregate() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+</li>
+ <li><a href="code.html#module-airflow.hooks.hive_hooks">airflow.hooks.hive_hooks (module)</a>
+</li>
<li><a href="code.html#module-airflow.macros">airflow.macros (module)</a>
</li>
<li><a href="code.html#module-airflow.models">airflow.models (module)</a>
@@ -229,6 +227,10 @@
</li>
<li><a href="code.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor">AwsRedshiftClusterSensor (class in airflow.contrib.sensors.aws_redshift_cluster_sensor)</a>, <a href="integration.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook">AzureDataLakeHook (class in airflow.contrib.hooks.azure_data_lake_hook)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook">AzureFileShareHook (class in airflow.contrib.hooks.azure_fileshare_hook)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook">[1]</a>
+</li>
</ul></td>
</tr></table>
@@ -259,10 +261,10 @@
</li>
<li><a href="code.html#airflow.contrib.operators.bigquery_check_operator.BigQueryIntervalCheckOperator">BigQueryIntervalCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_check_operator.BigQueryIntervalCheckOperator">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator">BigQueryOperator (class in airflow.contrib.operators.bigquery_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator">[1]</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator">BigQueryTableDeleteOperator (class in airflow.contrib.operators.bigquery_table_delete_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor">BigQueryTableSensor (class in airflow.contrib.sensors.bigquery_sensor)</a>
@@ -278,7 +280,13 @@
<li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator.build_job">build_job() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method)</a>
</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.bulk_dump">bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.bulk_dump">(airflow.hooks.mysql_hook.MySqlHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.bulk_dump">(airflow.hooks.postgres_hook.PostgresHook method)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.bulk_insert_rows">bulk_insert_rows() (airflow.hooks.oracle_hook.OracleHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.bulk_load">bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method)</a>
@@ -286,6 +294,8 @@
<ul>
<li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.bulk_load">(airflow.hooks.mysql_hook.MySqlHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.bulk_load">(airflow.hooks.postgres_hook.PostgresHook method)</a>
+</li>
</ul></li>
</ul></td>
</tr></table>
@@ -293,14 +303,34 @@
<h2 id="C">C</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.hooks.zendesk_hook.ZendeskHook.call">call() (airflow.hooks.zendesk_hook.ZendeskHook method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook">CassandraHook (class in airflow.contrib.hooks.cassandra_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator">CassandraToGoogleCloudStorageOperator (class in airflow.contrib.operators.cassandra_to_gcs)</a>
+</li>
<li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor">CeleryExecutor (class in airflow.executors.celery_executor)</a>
</li>
+ <li><a href="code.html#airflow.models.Chart">Chart (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_blob">check_for_blob() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_blob">[1]</a>
</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.check_for_bucket">check_for_bucket() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.check_for_bucket">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.check_for_directory">check_for_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.check_for_directory">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.check_for_file">check_for_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.check_for_file">[1]</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.check_for_file">(airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.check_for_file">[1]</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.check_for_key">check_for_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.check_for_key">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.check_for_named_partition">check_for_named_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.check_for_partition">check_for_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.webhdfs_hook.WebHDFSHook.check_for_path">check_for_path() (airflow.hooks.webhdfs_hook.WebHDFSHook method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_prefix">check_for_prefix() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_prefix">[1]</a>
@@ -311,6 +341,8 @@
</ul></li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.check_for_wildcard_key">check_for_wildcard_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.check_for_wildcard_key">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.http_hook.HttpHook.check_response">check_response() (airflow.hooks.http_hook.HttpHook method)</a>
+</li>
<li><a href="code.html#airflow.operators.check_operator.CheckOperator">CheckOperator (class in airflow.operators.check_operator)</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.clear">clear() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.clear">[1]</a>
@@ -333,14 +365,16 @@
</ul></li>
<li><a href="code.html#airflow.macros.hive.closest_ds_partition">closest_ds_partition() (in module airflow.macros.hive)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.cloudant_hook.CloudantHook">CloudantHook (class in airflow.contrib.hooks.cloudant_hook)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.cluster_status">cluster_status() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.cluster_status">[1]</a>
</li>
<li><a href="code.html#airflow.models.DagBag.collect_dags">collect_dags() (airflow.models.DagBag method)</a>
</li>
- <li><a href="code.html#airflow.models.TaskInstance.command">command() (airflow.models.TaskInstance method)</a>
-</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.models.TaskInstance.command">command() (airflow.models.TaskInstance method)</a>
+</li>
<li><a href="code.html#airflow.models.TaskInstance.command_as_list">command_as_list() (airflow.models.TaskInstance method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.commit">commit() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.commit">[1]</a>
@@ -350,22 +384,40 @@
<li><a href="code.html#airflow.models.Connection">Connection (class in airflow.models)</a>
</li>
<li><a href="code.html#airflow.operators.slack_operator.SlackAPIOperator.construct_api_call_params">construct_api_call_params() (airflow.operators.slack_operator.SlackAPIOperator method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.operators.slack_operator.SlackAPIPostOperator.construct_api_call_params">(airflow.operators.slack_operator.SlackAPIPostOperator method)</a>
+</li>
+ </ul></li>
+ <li><a href="code.html#airflow.operators.hive_to_druid.HiveToDruidTransfer.construct_ingest_query">construct_ingest_query() (airflow.operators.hive_to_druid.HiveToDruidTransfer method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator.convert_map_type">convert_map_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator.convert_tuple_type">convert_tuple_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator.convert_types">convert_types() (airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator.convert_user_type">convert_user_type() (airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator class method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.copy">copy() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.copy">[1]</a>
</li>
<li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.copy_expert">copy_expert() (airflow.hooks.postgres_hook.PostgresHook method)</a>
</li>
+ <li><a href="code.html#airflow.models.DagStat.create">create() (airflow.models.DagStat static method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.create_bucket">create_bucket() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.create_bucket">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.create_cluster">create_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.create_cluster">[1]</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.create_cluster_snapshot">create_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.create_cluster_snapshot">[1]</a>
</li>
<li><a href="code.html#airflow.models.DAG.create_dagrun">create_dagrun() (airflow.models.DAG method)</a>
</li>
- <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.create_directory">create_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.create_directory">create_directory() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.create_directory">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.create_directory">(airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.create_directory">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a>
</li>
</ul></li>
@@ -399,10 +451,14 @@
</li>
<li><a href="code.html#airflow.models.DagBag.dagbag_report">dagbag_report() (airflow.models.DagBag method)</a>
</li>
+ <li><a href="code.html#airflow.models.DagModel">DagModel (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.models.DagPickle">DagPickle (class in airflow.models)</a>
</li>
<li><a href="code.html#airflow.models.DagRun">DagRun (class in airflow.models)</a>
</li>
+ <li><a href="code.html#airflow.models.DagStat">DagStat (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.databricks_hook.DatabricksHook">DatabricksHook (class in airflow.contrib.hooks.databricks_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator">DatabricksSubmitRunOperator (class in airflow.contrib.operators.databricks_operator)</a>, <a href="integration.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator">[1]</a>
@@ -423,6 +479,8 @@
</li>
<li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator">DataprocClusterDeleteOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator">DataprocClusterScaleOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator">[1]</a>
+</li>
<li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator">DataProcHadoopOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcHiveOperator">DataProcHiveOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcHiveOperator">[1]</a>
@@ -443,14 +501,16 @@
</li>
<li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateOperator">DataprocWorkflowTemplateInstantiateOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateOperator">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator">DatastoreExportOperator (class in airflow.contrib.operators.datastore_export_operator)</a>, <a href="integration.html#airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook">DatastoreHook (class in airflow.contrib.hooks.datastore_hook)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator">DatastoreImportOperator (class in airflow.contrib.operators.datastore_import_operator)</a>, <a href="integration.html#airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator">[1]</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.hooks.cloudant_hook.CloudantHook.db">db() (airflow.contrib.hooks.cloudant_hook.CloudantHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook">DbApiHook (class in airflow.hooks.dbapi_hook)</a>
</li>
<li><a href="code.html#airflow.models.DAG.deactivate_stale_dags">deactivate_stale_dags() (airflow.models.DAG static method)</a>
@@ -459,8 +519,12 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.delete">delete() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.delete">[1]</a>
</li>
- <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">delete_cluster() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">[1]</a>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.delete_cluster">delete_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.delete_cluster">[1]</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">(airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">[1]</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.delete_directory">delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
<ul>
@@ -495,10 +559,24 @@
</li>
<li><a href="code.html#airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator">DiscordWebhookOperator (class in airflow.contrib.operators.discord_webhook_operator)</a>
</li>
+ <li><a href="code.html#airflow.hooks.docker_hook.DockerHook">DockerHook (class in airflow.hooks.docker_hook)</a>
+</li>
+ <li><a href="code.html#airflow.operators.docker_operator.DockerOperator">DockerOperator (class in airflow.operators.docker_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.download">download() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.download">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.download_file">download_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.download_file">[1]</a>
+</li>
<li><a href="code.html#airflow.models.BaseOperator.downstream_list">downstream_list (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.downstream_list">[1]</a>
</li>
+ <li><a href="code.html#airflow.operators.druid_check_operator.DruidCheckOperator">DruidCheckOperator (class in airflow.operators.druid_check_operator)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook">DruidDbApiHook (class in airflow.hooks.druid_hook)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidHook">DruidHook (class in airflow.hooks.druid_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.druid_operator.DruidOperator">DruidOperator (class in airflow.contrib.operators.druid_operator)</a>
+</li>
<li><a href="code.html#airflow.macros.ds_add">ds_add() (in module airflow.macros)</a>
</li>
<li><a href="code.html#airflow.macros.ds_format">ds_format() (in module airflow.macros)</a>
@@ -529,6 +607,16 @@
</li>
<li><a href="code.html#airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator">EmrTerminateJobFlowOperator (class in airflow.contrib.operators.emr_terminate_job_flow_operator)</a>, <a href="integration.html#airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.end">end() (airflow.contrib.executors.mesos_executor.MesosExecutor method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor.end">(airflow.executors.celery_executor.CeleryExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.local_executor.LocalExecutor.end">(airflow.executors.local_executor.LocalExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.sequential_executor.SequentialExecutor.end">(airflow.executors.sequential_executor.SequentialExecutor method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.models.TaskInstance.error">error() (airflow.models.TaskInstance method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook.execute">execute() (airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook method)</a>
@@ -544,6 +632,8 @@
</li>
<li><a href="code.html#airflow.contrib.operators.file_to_wasb.FileToWasbOperator.execute">(airflow.contrib.operators.file_to_wasb.FileToWasbOperator method)</a>, <a href="integration.html#airflow.contrib.operators.file_to_wasb.FileToWasbOperator.execute">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.mongo_to_s3.MongoToS3Operator.execute">(airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method)</a>
+</li>
<li><a href="code.html#airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator.execute">(airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator method)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator.execute">(airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator method)</a>
@@ -565,6 +655,16 @@
</ul></li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.execute_async">execute_async() (airflow.contrib.executors.mesos_executor.MesosExecutor method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor.execute_async">(airflow.executors.celery_executor.CeleryExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.local_executor.LocalExecutor.execute_async">(airflow.executors.local_executor.LocalExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.sequential_executor.SequentialExecutor.execute_async">(airflow.executors.sequential_executor.SequentialExecutor method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.exists">exists() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.exists">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook.export_table">export_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)</a>
@@ -593,8 +693,12 @@
</li>
<li><a href="code.html#airflow.sensors.hdfs_sensor.HdfsSensor.filter_for_ignored_ext">filter_for_ignored_ext() (airflow.sensors.hdfs_sensor.HdfsSensor static method)</a>
</li>
- <li><a href="code.html#airflow.models.DagRun.find">find() (airflow.models.DagRun static method)</a>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.find">find() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.models.DagRun.find">(airflow.models.DagRun static method)</a>
</li>
+ </ul></li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.models.DAG.folder">folder (airflow.models.DAG attribute)</a>
@@ -623,11 +727,27 @@
</li>
<li><a href="code.html#airflow.models.DAG.get_active_runs">get_active_runs() (airflow.models.DAG method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_autocommit">get_autocommit() (airflow.hooks.dbapi_hook.DbApiHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.get_autocommit">(airflow.hooks.mysql_hook.MySqlHook method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.get_bucket">get_bucket() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.get_bucket">[1]</a>
</li>
- <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_conn">get_conn() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_conn">[1]</a>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_cluster">get_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_cluster">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.get_collection">get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.get_conn">get_conn() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.get_conn">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_conn">(airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_conn">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_conn">(airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_conn">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook.get_conn">(airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_conn">(airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_conn">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.get_conn">(airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
@@ -644,28 +764,38 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_conn">(airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_conn">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.get_conn">(airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_conn">(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.redis_hook.RedisHook.get_conn">(airflow.contrib.hooks.redis_hook.RedisHook method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.get_conn">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.snowflake_hook.SnowflakeHook.get_conn">(airflow.contrib.hooks.snowflake_hook.SnowflakeHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.vertica_hook.VerticaHook.get_conn">(airflow.contrib.hooks.vertica_hook.VerticaHook method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_conn">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_conn">[1]</a>
</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_conn">(airflow.hooks.dbapi_hook.DbApiHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.get_conn">(airflow.hooks.druid_hook.DruidDbApiHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.hdfs_hook.HDFSHook.get_conn">(airflow.hooks.hdfs_hook.HDFSHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.http_hook.HttpHook.get_conn">(airflow.hooks.http_hook.HttpHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.jdbc_hook.JdbcHook.get_conn">(airflow.hooks.jdbc_hook.JdbcHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.mssql_hook.MsSqlHook.get_conn">(airflow.hooks.mssql_hook.MsSqlHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.get_conn">(airflow.hooks.mysql_hook.MySqlHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.get_conn">(airflow.hooks.oracle_hook.OracleHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.get_conn">(airflow.hooks.postgres_hook.PostgresHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_conn">(airflow.hooks.presto_hook.PrestoHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.sqlite_hook.SqliteHook.get_conn">(airflow.hooks.sqlite_hook.SqliteHook method)</a>
@@ -691,13 +821,23 @@
<li><a href="code.html#airflow.models.TaskInstance.get_dagrun">(airflow.models.TaskInstance method)</a>
</li>
</ul></li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_databases">get_databases() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
+ <li><a href="code.html#airflow.operators.druid_check_operator.DruidCheckOperator.get_db_hook">get_db_hook() (airflow.operators.druid_check_operator.DruidCheckOperator method)</a>
+</li>
<li><a href="code.html#airflow.models.BaseOperator.get_direct_relative_ids">get_direct_relative_ids() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_direct_relative_ids">[1]</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.get_direct_relatives">get_direct_relatives() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_direct_relatives">[1]</a>
</li>
<li><a href="code.html#airflow.models.get_fernet">get_fernet() (in module airflow.models)</a>
</li>
- <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">get_file() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">[1]</a>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file">get_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file">[1]</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">[1]</a>
+</li>
+ </ul></li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file_to_stream">get_file_to_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file_to_stream">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_first">get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
@@ -706,13 +846,15 @@
</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_first">(airflow.hooks.presto_hook.PrestoHook method)</a>
</li>
+ <li><a href="code.html#airflow.operators.druid_check_operator.DruidCheckOperator.get_first">(airflow.operators.druid_check_operator.DruidCheckOperator method)</a>
+</li>
</ul></li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.models.BaseOperator.get_flat_relative_ids">get_flat_relative_ids() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_flat_relative_ids">[1]</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.get_flat_relatives">get_flat_relatives() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_flat_relatives">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.hooks.qubole_hook.QuboleHook.get_jobs_id">get_jobs_id() (airflow.contrib.hooks.qubole_hook.QuboleHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.get_key">get_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.get_key">[1]</a>
@@ -727,6 +869,8 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_md5hash">get_md5hash() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_md5hash">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_metastore_client">get_metastore_client() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.get_model">get_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.get_model">[1]</a>
</li>
<li><a href="code.html#airflow.models.DAG.get_num_active_runs">get_num_active_runs() (airflow.models.DAG method)</a>
@@ -736,15 +880,27 @@
<li><a href="code.html#airflow.models.XCom.get_one">get_one() (airflow.models.XCom class method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_operation">get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_operation">[1]</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_operation">(airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_operation">[1]</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_pandas_df">get_pandas_df() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_pandas_df">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_pandas_df">(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_pandas_df">(airflow.hooks.dbapi_hook.DbApiHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.get_pandas_df">(airflow.hooks.druid_hook.DruidDbApiHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveServer2Hook.get_pandas_df">(airflow.hooks.hive_hooks.HiveServer2Hook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_pandas_df">(airflow.hooks.presto_hook.PrestoHook method)</a>
</li>
</ul></li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_partitions">get_partitions() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
<li><a href="code.html#airflow.models.DagRun.get_previous_dagrun">get_previous_dagrun() (airflow.models.DagRun method)</a>
</li>
<li><a href="code.html#airflow.models.DagRun.get_previous_scheduled_dagrun">get_previous_scheduled_dagrun() (airflow.models.DagRun method)</a>
@@ -754,6 +910,8 @@
<ul>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_records">(airflow.hooks.dbapi_hook.DbApiHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveServer2Hook.get_records">(airflow.hooks.hive_hooks.HiveServer2Hook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_records">(airflow.hooks.presto_hook.PrestoHook method)</a>
</li>
</ul></li>
@@ -769,6 +927,10 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_size">get_size() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_size">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_table">get_table() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_tables">get_tables() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+</li>
<li><a href="code.html#airflow.models.DagRun.get_task_instance">get_task_instance() (airflow.models.DagRun method)</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.get_task_instances">get_task_instances() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_task_instances">[1]</a>
@@ -780,9 +942,21 @@
<li><a href="code.html#airflow.models.DAG.get_template_env">get_template_env() (airflow.models.DAG method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_uri">get_uri() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.snowflake_hook.SnowflakeHook.get_uri">(airflow.contrib.hooks.snowflake_hook.SnowflakeHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.get_uri">(airflow.hooks.druid_hook.DruidDbApiHook method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.get_wildcard_key">get_wildcard_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.get_wildcard_key">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator">GKEClusterCreateOperator (class in airflow.contrib.operators.gcp_container_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator">GKEClusterDeleteOperator (class in airflow.contrib.operators.gcp_container_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook">GKEClusterHook (class in airflow.contrib.hooks.gcp_container_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook">[1]</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook">GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator">GoogleCloudStorageCreateBucketOperator (class in airflow.contrib.operators.gcs_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator">[1]</a>
@@ -821,16 +995,34 @@
</li>
<li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder">HdfsSensorFolder (class in airflow.contrib.sensors.hdfs_sensor)</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex">HdfsSensorRegex (class in airflow.contrib.sensors.hdfs_sensor)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.hipchat_operator.HipChatAPIOperator">HipChatAPIOperator (class in airflow.contrib.operators.hipchat_operator)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator">HipChatAPISendRoomNotificationOperator (class in airflow.contrib.operators.hipchat_operator)</a>
</li>
+ <li><a href="code.html#airflow.operators.hive_to_samba_operator.Hive2SambaOperator">Hive2SambaOperator (class in airflow.operators.hive_to_samba_operator)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook">HiveCliHook (class in airflow.hooks.hive_hooks)</a>
+</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook">HiveMetastoreHook (class in airflow.hooks.hive_hooks)</a>
+</li>
+ <li><a href="code.html#airflow.operators.hive_operator.HiveOperator">HiveOperator (class in airflow.operators.hive_operator)</a>
+</li>
<li><a href="code.html#airflow.sensors.hive_partition_sensor.HivePartitionSensor">HivePartitionSensor (class in airflow.sensors.hive_partition_sensor)</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveServer2Hook">HiveServer2Hook (class in airflow.hooks.hive_hooks)</a>
+</li>
+ <li><a href="code.html#airflow.operators.hive_stats_operator.HiveStatsCollectionOperator">HiveStatsCollectionOperator (class in airflow.operators.hive_stats_operator)</a>
+</li>
+ <li><a href="code.html#airflow.operators.hive_to_druid.HiveToDruidTransfer">HiveToDruidTransfer (class in airflow.operators.hive_to_druid)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator">HiveToDynamoDBTransferOperator (class in airflow.contrib.operators.hive_to_dynamodb)</a>
+</li>
+ <li><a href="code.html#airflow.operators.hive_to_mysql.HiveToMySqlTransfer">HiveToMySqlTransfer (class in airflow.operators.hive_to_mysql)</a>
+</li>
<li><a href="code.html#airflow.hooks.http_hook.HttpHook">HttpHook (class in airflow.hooks.http_hook)</a>
</li>
<li><a href="code.html#airflow.sensors.http_sensor.HttpSensor">HttpSensor (class in airflow.sensors.http_sensor)</a>
@@ -847,15 +1039,25 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook.import_table">import_table() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)</a>
</li>
+ <li><a href="code.html#airflow.models.ImportError">ImportError (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.models.TaskInstance.init_on_load">init_on_load() (airflow.models.TaskInstance method)</a>
</li>
<li><a href="code.html#airflow.models.TaskInstance.init_run_context">init_run_context() (airflow.models.TaskInstance method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.insert_many">insert_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.insert_one">insert_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.insert_rows">insert_rows() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.insert_rows">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.insert_rows">(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.insert_rows">(airflow.hooks.dbapi_hook.DbApiHook method)</a>
</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.insert_rows">(airflow.hooks.druid_hook.DruidDbApiHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.insert_rows">(airflow.hooks.oracle_hook.OracleHook method)</a>
</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.insert_rows">(airflow.hooks.presto_hook.PrestoHook method)</a>
@@ -865,8 +1067,12 @@
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.operators.check_operator.IntervalCheckOperator">IntervalCheckOperator (class in airflow.operators.check_operator)</a>
</li>
+ <li><a href="code.html#airflow.models.InvalidFernetToken">InvalidFernetToken</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook.invoke_lambda">invoke_lambda() (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method)</a>
</li>
+ <li><a href="code.html#airflow.models.TaskInstance.is_eligible_to_retry">is_eligible_to_retry() (airflow.models.TaskInstance method)</a>
+</li>
<li><a href="code.html#airflow.models.DAG.is_paused">is_paused (airflow.models.DAG attribute)</a>
</li>
<li><a href="code.html#airflow.models.TaskInstance.is_premature">is_premature (airflow.models.TaskInstance attribute)</a>
@@ -879,12 +1085,16 @@
<h2 id="J">J</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
- <li><a href="code.html#airflow.contrib.hooks.jenkins_hook.JenkinsHook">JenkinsHook (class in airflow.contrib.hooks.jenkins_hook)</a>
+ <li><a href="code.html#airflow.hooks.jdbc_hook.JdbcHook">JdbcHook (class in airflow.hooks.jdbc_hook)</a>
</li>
- <li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator">JenkinsJobTriggerOperator (class in airflow.contrib.operators.jenkins_job_trigger_operator)</a>
+ <li><a href="code.html#airflow.operators.jdbc_operator.JdbcOperator">JdbcOperator (class in airflow.operators.jdbc_operator)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.jenkins_hook.JenkinsHook">JenkinsHook (class in airflow.contrib.hooks.jenkins_hook)</a>
</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator">JenkinsJobTriggerOperator (class in airflow.contrib.operators.jenkins_job_trigger_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.jira_hook.JiraHook">JiraHook (class in airflow.contrib.hooks.jira_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.jira_operator.JiraOperator">JiraOperator (class in airflow.contrib.operators.jira_operator)</a>
@@ -901,14 +1111,22 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.redis_hook.RedisHook.key_exists">key_exists() (airflow.contrib.hooks.redis_hook.RedisHook method)</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.hooks.qubole_hook.QuboleHook.kill">kill() (airflow.contrib.hooks.qubole_hook.QuboleHook method)</a>
</li>
<li><a href="code.html#airflow.models.DagBag.kill_zombies">kill_zombies() (airflow.models.DagBag method)</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.models.KnownEvent">KnownEvent (class in airflow.models)</a>
+</li>
+ <li><a href="code.html#airflow.models.KnownEventType">KnownEventType (class in airflow.models)</a>
+</li>
+ <li><a href="code.html#airflow.models.KubeResourceVersion">KubeResourceVersion (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator">KubernetesPodOperator (class in airflow.contrib.operators.kubernetes_pod_operator)</a>, <a href="kubernetes.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator">[1]</a>
</li>
+ <li><a href="code.html#airflow.models.KubeWorkerIdentifier">KubeWorkerIdentifier (class in airflow.models)</a>
+</li>
</ul></td>
</tr></table>
@@ -921,6 +1139,8 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.list">list() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.list">[1]</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.list_directories_and_files">list_directories_and_files() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.list_directories_and_files">[1]</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.list_directory">list_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
<ul>
@@ -933,21 +1153,31 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.list_versions">list_versions() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.list_versions">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.load_bytes">load_bytes() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.load_bytes">[1]</a>
</li>
- <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_file">load_file() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_file">[1]</a>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook.load_df">load_df() (airflow.hooks.hive_hooks.HiveCliHook method)</a>
+</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_file">load_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_file">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_file">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_file">[1]</a>
+</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.load_file">(airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.load_file">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook.load_file">(airflow.hooks.hive_hooks.HiveCliHook method)</a>
+</li>
<li><a href="code.html#airflow.hooks.webhdfs_hook.WebHDFSHook.load_file">(airflow.hooks.webhdfs_hook.WebHDFSHook method)</a>
</li>
</ul></li>
- <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_string">load_string() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_string">[1]</a>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_stream">load_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_stream">[1]</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_string">load_string() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.load_string">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_string">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.load_string">[1]</a>
+</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.load_string">(airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.load_string">[1]</a>
</li>
</ul></li>
@@ -963,8 +1193,12 @@
<h2 id="M">M</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
- <li><a href="code.html#airflow.macros.hive.max_partition">max_partition() (in module airflow.macros.hive)</a>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.max_partition">max_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.macros.hive.max_partition">(in module airflow.macros.hive)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor">MesosExecutor (class in airflow.contrib.executors.mesos_executor)</a>
</li>
<li><a href="code.html#airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor">MetastorePartitionSensor (class in airflow.sensors.metastore_partition_sensor)</a>
@@ -975,22 +1209,30 @@
</li>
<li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineModelOperator">MLEngineModelOperator (class in airflow.contrib.operators.mlengine_operator)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineModelOperator">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator">MLEngineTrainingOperator (class in airflow.contrib.operators.mlengine_operator)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator">MLEngineVersionOperator (class in airflow.contrib.operators.mlengine_operator)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator">[1]</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook">MongoHook (class in airflow.contrib.hooks.mongo_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.mongo_to_s3.MongoToS3Operator">MongoToS3Operator (class in airflow.contrib.operators.mongo_to_s3)</a>
+</li>
<li><a href="code.html#airflow.hooks.mssql_hook.MsSqlHook">MsSqlHook (class in airflow.hooks.mssql_hook)</a>
</li>
<li><a href="code.html#airflow.operators.mssql_operator.MsSqlOperator">MsSqlOperator (class in airflow.operators.mssql_operator)</a>
</li>
+ <li><a href="code.html#airflow.operators.mssql_to_hive.MsSqlToHiveTransfer">MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive)</a>
+</li>
<li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook">MySqlHook (class in airflow.hooks.mysql_hook)</a>
</li>
<li><a href="code.html#airflow.operators.mysql_operator.MySqlOperator">MySqlOperator (class in airflow.operators.mysql_operator)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator">MySqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mysql_to_gcs)</a>
</li>
+ <li><a href="code.html#airflow.operators.mysql_to_hive.MySqlToHiveTransfer">MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)</a>
+</li>
</ul></td>
</tr></table>
@@ -999,22 +1241,28 @@
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor">NamedHivePartitionSensor (class in airflow.sensors.named_hive_partition_sensor)</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.models.TaskInstance.next_retry_datetime">next_retry_datetime() (airflow.models.TaskInstance method)</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.models.DAG.normalize_schedule">normalize_schedule() (airflow.models.DAG method)</a>
</li>
+ <li><a href="code.html#airflow.models.NullFernet">NullFernet (class in airflow.models)</a>
+</li>
</ul></td>
</tr></table>
<h2 id="O">O</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.hooks.segment_hook.SegmentHook.on_error">on_error() (airflow.contrib.hooks.segment_hook.SegmentHook method)</a>
+</li>
<li><a href="code.html#airflow.models.BaseOperator.on_kill">on_kill() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.on_kill">[1]</a>
</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.models.Pool.open_slots">open_slots() (airflow.models.Pool method)</a>
+</li>
<li><a href="code.html#airflow.hooks.oracle_hook.OracleHook">OracleHook (class in airflow.hooks.oracle_hook)</a>
</li>
<li><a href="code.html#airflow.operators.oracle_operator.OracleOperator">OracleOperator (class in airflow.operators.oracle_operator)</a>
@@ -1031,20 +1279,80 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook">PinotDbApiHook (class in airflow.contrib.hooks.pinot_hook)</a>
</li>
- <li><a href="code.html#airflow.contrib.sensors.bash_sensor.BashSensor.poke">poke() (airflow.contrib.sensors.bash_sensor.BashSensor method)</a>
+ <li><a href="code.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor.poke">poke() (airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor method)</a>, <a href="integration.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor.poke">[1]</a>
<ul>
+ <li><a href="code.html#airflow.contrib.sensors.bash_sensor.BashSensor.poke">(airflow.contrib.sensors.bash_sensor.BashSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor.poke">(airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.datadog_sensor.DatadogSensor.poke">(airflow.contrib.sensors.datadog_sensor.DatadogSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor.poke">(airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.file_sensor.FileSensor.poke">(airflow.contrib.sensors.file_sensor.FileSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.ftp_sensor.FTPSensor.poke">(airflow.contrib.sensors.ftp_sensor.FTPSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor method)</a>
+</li>
<li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder.poke">(airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder method)</a>
</li>
<li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex.poke">(airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.sensors.jira_sensor.JiraSensor.poke">(airflow.contrib.sensors.jira_sensor.JiraSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor.poke">(airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.qubole_sensor.QuboleSensor.poke">(airflow.contrib.sensors.qubole_sensor.QuboleSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.redis_key_sensor.RedisKeySensor.poke">(airflow.contrib.sensors.redis_key_sensor.RedisKeySensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.sftp_sensor.SFTPSensor.poke">(airflow.contrib.sensors.sftp_sensor.SFTPSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor.poke">(airflow.contrib.sensors.wasb_sensor.WasbBlobSensor method)</a>, <a href="integration.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor.poke">[1]</a>
+</li>
+ <li><a href="integration.html#airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor.poke">(airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor method)</a>
+</li>
<li><a href="code.html#airflow.sensors.base_sensor_operator.BaseSensorOperator.poke">(airflow.sensors.base_sensor_operator.BaseSensorOperator method)</a>
</li>
+ <li><a href="code.html#airflow.sensors.external_task_sensor.ExternalTaskSensor.poke">(airflow.sensors.external_task_sensor.ExternalTaskSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.hdfs_sensor.HdfsSensor.poke">(airflow.sensors.hdfs_sensor.HdfsSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.hive_partition_sensor.HivePartitionSensor.poke">(airflow.sensors.hive_partition_sensor.HivePartitionSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.http_sensor.HttpSensor.poke">(airflow.sensors.http_sensor.HttpSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor.poke">(airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor.poke">(airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.s3_key_sensor.S3KeySensor.poke">(airflow.sensors.s3_key_sensor.S3KeySensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.s3_prefix_sensor.S3PrefixSensor.poke">(airflow.sensors.s3_prefix_sensor.S3PrefixSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.sql_sensor.SqlSensor.poke">(airflow.sensors.sql_sensor.SqlSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.time_delta_sensor.TimeDeltaSensor.poke">(airflow.sensors.time_delta_sensor.TimeDeltaSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.time_sensor.TimeSensor.poke">(airflow.sensors.time_sensor.TimeSensor method)</a>
+</li>
+ <li><a href="code.html#airflow.sensors.web_hdfs_sensor.WebHdfsSensor.poke">(airflow.sensors.web_hdfs_sensor.WebHdfsSensor method)</a>
+</li>
</ul></li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator.poll_job_in_queue">poll_job_in_queue() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.poll_operation_until_done">poll_operation_until_done() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.poll_operation_until_done">[1]</a>
</li>
+ <li><a href="code.html#airflow.models.Pool">Pool (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.models.TaskInstance.pool_full">pool_full() (airflow.models.TaskInstance method)</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook.Popen">Popen() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)</a>
@@ -1062,11 +1370,13 @@
<li><a href="code.html#airflow.models.BaseOperator.pre_execute">pre_execute() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.pre_execute">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.operators.hipchat_operator.HipChatAPIOperator.prepare_request">prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator.prepare_request">(airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator method)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.models.BaseOperator.prepare_template">prepare_template() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.prepare_template">[1]</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.operators.presto_check_operator.PrestoCheckOperator">PrestoCheckOperator (class in airflow.operators.presto_check_operator)</a>
</li>
<li><a href="code.html#airflow.hooks.presto_hook.PrestoHook">PrestoHook (class in airflow.hooks.presto_hook)</a>
@@ -1111,6 +1421,8 @@
<h2 id="Q">Q</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator">QuboleCheckOperator (class in airflow.contrib.operators.qubole_check_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.qubole_hook.QuboleHook">QuboleHook (class in airflow.contrib.hooks.qubole_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.qubole_operator.QuboleOperator">QuboleOperator (class in airflow.contrib.operators.qubole_operator)</a>
@@ -1119,20 +1431,28 @@
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.sensors.qubole_sensor.QuboleSensor">QuboleSensor (class in airflow.contrib.sensors.qubole_sensor)</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator">QuboleValueCheckOperator (class in airflow.contrib.operators.qubole_check_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook.query_metric">query_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method)</a>
</li>
+ <li><a href="code.html#airflow.models.Pool.queued_slots">queued_slots() (airflow.models.Pool method)</a>
+</li>
</ul></td>
</tr></table>
<h2 id="R">R</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.macros.random">random() (in module airflow.macros)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.read_file">read_file() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.read_file">[1]</a>
</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.read_key">read_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.read_key">[1]</a>
</li>
<li><a href="code.html#airflow.models.TaskInstance.ready_for_retry">ready_for_retry() (airflow.models.TaskInstance method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook.record_exists">record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.redis_hook.RedisHook">RedisHook (class in airflow.contrib.hooks.redis_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.sensors.redis_key_sensor.RedisKeySensor">RedisKeySensor (class in airflow.contrib.sensors.redis_key_sensor)</a>
@@ -1181,14 +1501,20 @@
</ul></li>
<li><a href="code.html#airflow.hooks.http_hook.HttpHook.run_and_check">run_and_check() (airflow.hooks.http_hook.HttpHook method)</a>
</li>
- <li><a href="code.html#airflow.hooks.pig_hook.PigCliHook.run_cli">run_cli() (airflow.hooks.pig_hook.PigCliHook method)</a>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook.run_cli">run_cli() (airflow.hooks.hive_hooks.HiveCliHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.hooks.pig_hook.PigCliHook.run_cli">(airflow.hooks.pig_hook.PigCliHook method)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.run_query">run_query() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.run_query">[1]</a>
<ul>
<li><a href="code.html#airflow.contrib.hooks.spark_sql_hook.SparkSqlHook.run_query">(airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method)</a>
</li>
</ul></li>
+ <li><a href="code.html#airflow.hooks.http_hook.HttpHook.run_with_advanced_retry">run_with_advanced_retry() (airflow.hooks.http_hook.HttpHook method)</a>
+</li>
</ul></td>
</tr></table>
@@ -1207,12 +1533,20 @@
</li>
<li><a href="code.html#airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator">S3ToGoogleCloudStorageOperator (class in airflow.contrib.operators.s3_to_gcs_operator)</a>, <a href="integration.html#airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator">[1]</a>
</li>
+ <li><a href="code.html#airflow.operators.s3_to_hive_operator.S3ToHiveTransfer">S3ToHiveTransfer (class in airflow.operators.s3_to_hive_operator)</a>, <a href="integration.html#airflow.operators.s3_to_hive_operator.S3ToHiveTransfer">[1]</a>
+</li>
<li><a href="code.html#airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer">S3ToRedshiftTransfer (class in airflow.operators.s3_to_redshift_operator)</a>, <a href="integration.html#airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer">[1]</a>
</li>
+ <li><a href="code.html#airflow.hooks.samba_hook.SambaHook">SambaHook (class in airflow.hooks.samba_hook)</a>
+</li>
<li><a href="code.html#airflow.models.BaseOperator.schedule_interval">schedule_interval (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.schedule_interval">[1]</a>
</li>
<li><a href="kubernetes.html#airflow.contrib.kubernetes.secret.Secret">Secret (class in airflow.contrib.kubernetes.secret)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.segment_hook.SegmentHook">SegmentHook (class in airflow.contrib.hooks.segment_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator">SegmentTrackEventOperator (class in airflow.contrib.operators.segment_track_event_operator)</a>
+</li>
<li><a href="code.html#airflow.hooks.S3_hook.S3Hook.select_key">select_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.select_key">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook.send_metric">send_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method)</a>
@@ -1221,16 +1555,34 @@
</li>
<li><a href="code.html#airflow.models.XCom.set">set() (airflow.models.XCom class method)</a>
</li>
- <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.set_autocommit">set_autocommit() (airflow.hooks.dbapi_hook.DbApiHook method)</a>
+ <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.set_autocommit">set_autocommit() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.contrib.hooks.snowflake_hook.SnowflakeHook.set_autocommit">(airflow.contrib.hooks.snowflake_hook.SnowflakeHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.set_autocommit">(airflow.hooks.dbapi_hook.DbApiHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.set_autocommit">(airflow.hooks.druid_hook.DruidDbApiHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.jdbc_hook.JdbcHook.set_autocommit">(airflow.hooks.jdbc_hook.JdbcHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.mssql_hook.MsSqlHook.set_autocommit">(airflow.hooks.mssql_hook.MsSqlHook method)</a>
+</li>
+ <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.set_autocommit">(airflow.hooks.mysql_hook.MySqlHook method)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.set_default_version">set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.set_default_version">[1]</a>
</li>
<li><a href="code.html#airflow.models.DAG.set_dependency">set_dependency() (airflow.models.DAG method)</a>
</li>
+ <li><a href="code.html#airflow.models.DagStat.set_dirty">set_dirty() (airflow.models.DagStat static method)</a>
+</li>
<li><a href="code.html#airflow.models.BaseOperator.set_downstream">set_downstream() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.set_downstream">[1]</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.set_upstream">set_upstream() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.set_upstream">[1]</a>
</li>
+ <li><a href="code.html#airflow.models.Variable.setdefault">setdefault() (airflow.models.Variable class method)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook">SFTPHook (class in airflow.contrib.hooks.sftp_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.sftp_operator.SFTPOperator">SFTPOperator (class in airflow.contrib.operators.sftp_operator)</a>
@@ -1239,14 +1591,16 @@
</li>
<li><a href="code.html#airflow.operators.python_operator.ShortCircuitOperator">ShortCircuitOperator (class in airflow.operators.python_operator)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook.shutdown_cluster">shutdown_cluster() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a>
+</li>
<li><a href="code.html#airflow.operators.http_operator.SimpleHttpOperator">SimpleHttpOperator (class in airflow.operators.http_operator)</a>
</li>
+ </ul></td>
+ <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.models.DagBag.size">size() (airflow.models.DagBag method)</a>
</li>
<li><a href="code.html#airflow.operators.slack_operator.SlackAPIOperator">SlackAPIOperator (class in airflow.operators.slack_operator)</a>
</li>
- </ul></td>
- <td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.operators.slack_operator.SlackAPIPostOperator">SlackAPIPostOperator (class in airflow.operators.slack_operator)</a>
</li>
<li><a href="code.html#airflow.hooks.slack_hook.SlackHook">SlackHook (class in airflow.hooks.slack_hook)</a>
@@ -1257,6 +1611,10 @@
</li>
<li><a href="code.html#airflow.models.SlaMiss">SlaMiss (class in airflow.models)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.snowflake_hook.SnowflakeHook">SnowflakeHook (class in airflow.contrib.hooks.snowflake_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.snowflake_operator.SnowflakeOperator">SnowflakeOperator (class in airflow.contrib.operators.snowflake_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.spark_jdbc_hook.SparkJDBCHook">SparkJDBCHook (class in airflow.contrib.hooks.spark_jdbc_hook)</a>
</li>
<li><a href="code.html#airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator">SparkJDBCOperator (class in airflow.contrib.operators.spark_jdbc_operator)</a>
@@ -1283,6 +1641,14 @@
</li>
<li><a href="code.html#airflow.contrib.operators.ssh_operator.SSHOperator">SSHOperator (class in airflow.contrib.operators.ssh_operator)</a>
</li>
+ <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.start">start() (airflow.contrib.executors.mesos_executor.MesosExecutor method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor.start">(airflow.executors.celery_executor.CeleryExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.local_executor.LocalExecutor.start">(airflow.executors.local_executor.LocalExecutor method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.store_file">store_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a>
<ul>
@@ -1299,6 +1665,16 @@
</li>
<li><a href="code.html#airflow.contrib.hooks.databricks_hook.DatabricksHook.submit_run">submit_run() (airflow.contrib.hooks.databricks_hook.DatabricksHook method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.sync">sync() (airflow.contrib.executors.mesos_executor.MesosExecutor method)</a>
+
+ <ul>
+ <li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor.sync">(airflow.executors.celery_executor.CeleryExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.local_executor.LocalExecutor.sync">(airflow.executors.local_executor.LocalExecutor method)</a>
+</li>
+ <li><a href="code.html#airflow.executors.sequential_executor.SequentialExecutor.sync">(airflow.executors.sequential_executor.SequentialExecutor method)</a>
+</li>
+ </ul></li>
<li><a href="code.html#airflow.models.DAG.sync_to_db">sync_to_db() (airflow.models.DAG method)</a>
</li>
</ul></td>
@@ -1308,21 +1684,29 @@
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.table_exists">table_exists() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.table_exists">[1]</a>
+
+ <ul>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.table_exists">(airflow.hooks.hive_hooks.HiveMetastoreHook method)</a>
</li>
+ </ul></li>
<li><a href="code.html#airflow.models.TaskFail">TaskFail (class in airflow.models)</a>
</li>
<li><a href="code.html#airflow.models.TaskInstance">TaskInstance (class in airflow.models)</a>
</li>
<li><a href="code.html#airflow.models.DAG.test_cycle">test_cycle() (airflow.models.DAG method)</a>
</li>
- <li><a href="code.html#airflow.sensors.time_delta_sensor.TimeDeltaSensor">TimeDeltaSensor (class in airflow.sensors.time_delta_sensor)</a>
+ <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook.test_hql">test_hql() (airflow.hooks.hive_hooks.HiveCliHook method)</a>
</li>
- <li><a href="code.html#airflow.sensors.time_sensor.TimeSensor">TimeSensor (class in airflow.sensors.time_sensor)</a>
+ <li><a href="code.html#airflow.sensors.time_delta_sensor.TimeDeltaSensor">TimeDeltaSensor (class in airflow.sensors.time_delta_sensor)</a>
</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.sensors.time_sensor.TimeSensor">TimeSensor (class in airflow.sensors.time_sensor)</a>
+</li>
<li><a href="code.html#airflow.models.DAG.topological_sort">topological_sort() (airflow.models.DAG method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.mongo_to_s3.MongoToS3Operator.transform">transform() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method)</a>
+</li>
<li><a href="code.html#airflow.models.DAG.tree_view">tree_view() (airflow.models.DAG method)</a>
</li>
<li><a href="code.html#airflow.operators.dagrun_operator.TriggerDagRunOperator">TriggerDagRunOperator (class in airflow.operators.dagrun_operator)</a>
@@ -1341,14 +1725,22 @@
<h2 id="U">U</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.models.DagStat.update">update() (airflow.models.DagStat static method)</a>
+</li>
<li><a href="code.html#airflow.models.DagRun.update_state">update_state() (airflow.models.DagRun method)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.upload">upload() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.upload">[1]</a>
+</li>
</ul></td>
<td style="width: 33%; vertical-align: top;"><ul>
- <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.upload">upload() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.upload">[1]</a>
+ <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.upload_file">upload_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.upload_file">[1]</a>
</li>
<li><a href="code.html#airflow.models.BaseOperator.upstream_list">upstream_list (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.upstream_list">[1]</a>
</li>
+ <li><a href="code.html#airflow.models.Pool.used_slots">used_slots() (airflow.models.Pool method)</a>
+</li>
+ <li><a href="code.html#airflow.models.User">User (class in airflow.models)</a>
+</li>
</ul></td>
</tr></table>
@@ -1357,6 +1749,8 @@
<td style="width: 33%; vertical-align: top;"><ul>
<li><a href="code.html#airflow.operators.check_operator.ValueCheckOperator">ValueCheckOperator (class in airflow.operators.check_operator)</a>
</li>
+ <li><a href="code.html#airflow.models.Variable">Variable (class in airflow.models)</a>
+</li>
<li><a href="code.html#airflow.models.DagRun.verify_integrity">verify_integrity() (airflow.models.DagRun method)</a>
</li>
</ul></td>
@@ -1365,12 +1759,18 @@
</li>
<li><a href="code.html#airflow.contrib.operators.vertica_operator.VerticaOperator">VerticaOperator (class in airflow.contrib.operators.vertica_operator)</a>
</li>
+ <li><a href="code.html#airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer">VerticaToHiveTransfer (class in airflow.contrib.operators.vertica_to_hive)</a>
+</li>
</ul></td>
</tr></table>
<h2 id="W">W</h2>
<table style="width: 100%" class="indextable genindextable"><tr>
<td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook.wait">wait() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.wait_for_operation">wait_for_operation() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.wait_for_operation">[1]</a>
+</li>
<li><a href="code.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor">WasbBlobSensor (class in airflow.contrib.sensors.wasb_sensor)</a>, <a href="integration.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor">[1]</a>
</li>
<li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook">WasbHook (class in airflow.contrib.hooks.wasb_hook)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook">[1]</a>
@@ -1383,6 +1783,10 @@
</li>
<li><a href="code.html#airflow.sensors.web_hdfs_sensor.WebHdfsSensor">WebHdfsSensor (class in airflow.sensors.web_hdfs_sensor)</a>
</li>
+ <li><a href="code.html#airflow.contrib.hooks.winrm_hook.WinRMHook">WinRMHook (class in airflow.contrib.hooks.winrm_hook)</a>
+</li>
+ <li><a href="code.html#airflow.contrib.operators.winrm_operator.WinRMOperator">WinRMOperator (class in airflow.contrib.operators.winrm_operator)</a>
+</li>
<li><a href="code.html#airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook.write_batch_data">write_batch_data() (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method)</a>
</li>
</ul></td>
@@ -1410,12 +1814,18 @@
</ul></td>
</tr></table>
+<h2 id="Z">Z</h2>
+<table style="width: 100%" class="indextable genindextable"><tr>
+ <td style="width: 33%; vertical-align: top;"><ul>
+ <li><a href="code.html#airflow.hooks.zendesk_hook.ZendeskHook">ZendeskHook (class in airflow.hooks.zendesk_hook)</a>
+</li>
+ </ul></td>
+</tr></table>
+
</div>
- <div class="articleComments">
-
- </div>
+
</div>
<footer>
@@ -1427,7 +1837,7 @@
</p>
</div>
- Built with <a href="http://sphinx-doc.org/">Sphinx</a> using a <a href="https://github.com/snide/sphinx_rtd_theme">theme</a> prov
<TRUNCATED>