| |
| |
| |
| <!DOCTYPE html> |
| <!--[if IE 8]><html class="no-js lt-ie9" lang="en" > <![endif]--> |
| <!--[if gt IE 8]><!--> <html class="no-js" lang="en" > <!--<![endif]--> |
| <head> |
| <meta charset="utf-8"> |
| |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> |
| |
| <title>Index — Airflow Documentation</title> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| <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> |
| |
| <script type="application/javascript"> |
| window.ga=window.ga||function(){(ga.q=ga.q||[]).push(arguments)};ga.l=+new Date; |
| ga("create", "UA-140539454-1", "auto"); |
| ga("send", "pageview"); |
| </script> |
| <script async src="https://www.google-analytics.com/analytics.js"></script> |
| </head> |
| |
| |
| <body class="wy-body-for-nav"> |
| |
| |
| <div class="wy-grid-for-nav"> |
| |
| |
| <nav data-toggle="wy-nav-shift" class="wy-nav-side"> |
| <div class="wy-side-scroll"> |
| <div class="wy-side-nav-search"> |
| |
| |
| |
| <a href="index.html" class="icon icon-home"> Airflow |
| |
| |
| |
| </a> |
| |
| |
| |
| |
| <div class="version"> |
| 1.10.2 |
| </div> |
| |
| |
| |
| |
| <div role="search"> |
| <form id="rtd-search-form" class="wy-form" action="search.html" method="get"> |
| <input type="text" name="q" placeholder="Search docs" /> |
| <input type="hidden" name="check_keywords" value="yes" /> |
| <input type="hidden" name="area" value="default" /> |
| </form> |
| </div> |
| |
| |
| </div> |
| |
| <div class="wy-menu wy-menu-vertical" data-spy="affix" role="navigation" aria-label="main navigation"> |
| |
| |
| |
| |
| |
| |
| <ul> |
| <li class="toctree-l1"><a class="reference internal" href="project.html">Project</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="license.html">License</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="start.html">Quick Start</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="installation.html">Installation</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="tutorial.html">Tutorial</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="howto/index.html">How-to Guides</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="ui.html">UI / Screenshots</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="concepts.html">Concepts</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="profiling.html">Data Profiling</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="cli.html">Command Line Interface</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="scheduler.html">Scheduling & Triggers</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="plugins.html">Plugins</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="security.html">Security</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="timezone.html">Time zones</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="api.html">Experimental Rest API</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="integration.html">Integration</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="metrics.html">Metrics</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="kubernetes.html">Kubernetes</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="lineage.html">Lineage</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="changelog.html">Changelog</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="faq.html">FAQ</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="code.html">API Reference</a></li> |
| </ul> |
| |
| |
| |
| </div> |
| </div> |
| </nav> |
| |
| <section data-toggle="wy-nav-shift" class="wy-nav-content-wrap"> |
| |
| |
| <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> |
| |
| </nav> |
| |
| |
| <div class="wy-nav-content"> |
| |
| <div class="rst-content"> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| <div role="navigation" aria-label="breadcrumbs navigation"> |
| |
| <ul class="wy-breadcrumbs"> |
| |
| <li><a href="index.html">Docs</a> »</li> |
| |
| <li></li> |
| |
| |
| <li class="wy-breadcrumbs-aside"> |
| |
| |
| |
| </li> |
| |
| </ul> |
| |
| |
| <hr/> |
| </div> |
| <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article"> |
| <div itemprop="articleBody"> |
| |
| |
| <h1 id="index">Index</h1> |
| |
| <div class="genindex-jumpbox"> |
| <a href="#A"><strong>A</strong></a> |
| | <a href="#B"><strong>B</strong></a> |
| | <a href="#C"><strong>C</strong></a> |
| | <a href="#D"><strong>D</strong></a> |
| | <a href="#E"><strong>E</strong></a> |
| | <a href="#F"><strong>F</strong></a> |
| | <a href="#G"><strong>G</strong></a> |
| | <a href="#H"><strong>H</strong></a> |
| | <a href="#I"><strong>I</strong></a> |
| | <a href="#J"><strong>J</strong></a> |
| | <a href="#K"><strong>K</strong></a> |
| | <a href="#L"><strong>L</strong></a> |
| | <a href="#M"><strong>M</strong></a> |
| | <a href="#N"><strong>N</strong></a> |
| | <a href="#O"><strong>O</strong></a> |
| | <a href="#P"><strong>P</strong></a> |
| | <a href="#Q"><strong>Q</strong></a> |
| | <a href="#R"><strong>R</strong></a> |
| | <a href="#S"><strong>S</strong></a> |
| | <a href="#T"><strong>T</strong></a> |
| | <a href="#U"><strong>U</strong></a> |
| | <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> |
| <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_pubsub_hook.PubSubHook.acknowledge">acknowledge() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.add_task">add_task() (airflow.models.DAG method)</a> |
| </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.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator">AdlsToGoogleCloudStorageOperator (class in airflow.contrib.operators.adls_to_gcs)</a>, <a href="integration.html#airflow.contrib.operators.adls_to_gcs.AdlsToGoogleCloudStorageOperator">[1]</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.allocate_ids">allocate_ids() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.allocate_ids">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.are_dependencies_met">are_dependencies_met() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.are_dependents_done">are_dependents_done() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.aws_athena_sensor.AthenaSensor">AthenaSensor (class in airflow.contrib.sensors.aws_athena_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook.await">await() (airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook">AWSAthenaHook (class in airflow.contrib.hooks.aws_athena_hook)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator">AWSAthenaOperator (class in airflow.contrib.operators.aws_athena_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.awsbatch_operator.AWSBatchOperator">AWSBatchOperator (class in airflow.contrib.operators.awsbatch_operator)</a>, <a href="integration.html#airflow.contrib.operators.awsbatch_operator.AWSBatchOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook">AwsDynamoDBHook (class in airflow.contrib.hooks.aws_dynamodb_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook">AwsFirehoseHook (class in airflow.contrib.hooks.aws_firehose_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook">AwsGlueCatalogHook (class in airflow.contrib.hooks.aws_glue_catalog_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor">AwsGlueCatalogPartitionSensor (class in airflow.contrib.sensors.aws_glue_catalog_partition_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_hook.AwsHook">AwsHook (class in airflow.contrib.hooks.aws_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook">AwsLambdaHook (class in airflow.contrib.hooks.aws_lambda_hook)</a> |
| </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_cosmos_hook.AzureCosmosDBHook">AzureCosmosDBHook (class in airflow.contrib.hooks.azure_cosmos_hook)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor">AzureCosmosDocumentSensor (class in airflow.contrib.sensors.azure_cosmos_sensor)</a>, <a href="integration.html#airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator">AzureCosmosInsertDocumentOperator (class in airflow.contrib.operators.azure_cosmos_operator)</a>, <a href="integration.html#airflow.contrib.operators.azure_cosmos_operator.AzureCosmosInsertDocumentOperator">[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.operators.adls_list_operator.AzureDataLakeStorageListOperator">AzureDataLakeStorageListOperator (class in airflow.contrib.operators.adls_list_operator)</a>, <a href="integration.html#airflow.contrib.operators.adls_list_operator.AzureDataLakeStorageListOperator">[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> |
| |
| <h2 id="B">B</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.DagBag.bag_dag">bag_dag() (airflow.models.DagBag method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator">BaseOperator (class in airflow.models)</a>, <a href="code.html#airflow.models.BaseOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.base_sensor_operator.BaseSensorOperator">BaseSensorOperator (class in airflow.sensors.base_sensor_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.bash_operator.BashOperator">BashOperator (class in airflow.operators.bash_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.bash_sensor.BashSensor">BashSensor (class in airflow.contrib.sensors.bash_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.begin_transaction">begin_transaction() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.begin_transaction">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator">BigQueryCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_check_operator.BigQueryCheckOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator">BigQueryCreateEmptyDatasetOperator (class in airflow.contrib.operators.bigquery_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyDatasetOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator">BigQueryCreateEmptyTableOperator (class in airflow.contrib.operators.bigquery_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator">BigQueryCreateExternalTableOperator (class in airflow.contrib.operators.bigquery_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator">BigQueryDeleteDatasetOperator (class in airflow.contrib.operators.bigquery_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator">BigQueryGetDataOperator (class in airflow.contrib.operators.bigquery_get_data)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook">BigQueryHook (class in airflow.contrib.hooks.bigquery_hook)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook">[1]</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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> |
| <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> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator">BigQueryToBigQueryOperator (class in airflow.contrib.operators.bigquery_to_bigquery)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator">BigQueryToCloudStorageOperator (class in airflow.contrib.operators.bigquery_to_gcs)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator">BigQueryValueCheckOperator (class in airflow.contrib.operators.bigquery_check_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_check_operator.BigQueryValueCheckOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.BranchPythonOperator">BranchPythonOperator (class in airflow.operators.python_operator)</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.dbapi_hook.DbApiHook.bulk_load">bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| |
| <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> |
| |
| <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.sensors.cassandra_record_sensor.CassandraRecordSensor">CassandraRecordSensor (class in airflow.contrib.sensors.cassandra_record_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor">CassandraTableSensor (class in airflow.contrib.sensors.cassandra_table_sensor)</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.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook.check_for_partition">check_for_partition() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.check_for_partition">(airflow.hooks.hive_hooks.HiveMetastoreHook method)</a> |
| </li> |
| </ul></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> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.check_for_prefix">(airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.check_for_prefix">[1]</a> |
| </li> |
| </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.contrib.hooks.aws_athena_hook.AWSAthenaHook.check_query_status">check_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</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.contrib.hooks.sagemaker_hook.SageMakerHook.check_s3_url">check_s3_url() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_s3_url">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_s3_url">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_status">check_status() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_status">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_status">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_config">check_training_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_config">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_config">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_status_with_log">check_training_status_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_status_with_log">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_training_status_with_log">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_tuning_config">check_tuning_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_tuning_config">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_tuning_config">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.check_operator.CheckOperator">CheckOperator (class in airflow.operators.check_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.cleanup_database_hook">cleanup_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</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> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.DAG.clear">(airflow.models.DAG method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.executors.kubernetes_executor.KubernetesExecutor.clear_not_launched_queued_tasks">clear_not_launched_queued_tasks() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.clear_task_instances">clear_task_instances() (in module airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.clear_xcom_data">clear_xcom_data() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.cli">cli() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.close_conn">close_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.close_conn">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </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="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook">CloudSqlDatabaseHook (class in airflow.contrib.hooks.gcp_sql_hook)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook">CloudSqlHook (class in airflow.contrib.hooks.gcp_sql_hook)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator">CloudSqlInstanceCreateOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator">CloudSqlInstanceDatabaseCreateOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator">CloudSqlInstanceDatabaseDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator">CloudSqlInstanceDatabasePatchOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator">CloudSqlInstanceDeleteOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceExportOperator">CloudSqlInstanceExportOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceImportOperator">CloudSqlInstanceImportOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator">CloudSqlInstancePatchOperator (class in airflow.contrib.operators.gcp_sql_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner">CloudSqlProxyRunner (class in airflow.contrib.hooks.gcp_sql_hook)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlQueryOperator">CloudSqlQueryOperator (class in airflow.contrib.operators.gcp_sql_operator)</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> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.concurrency_reached">concurrency_reached (airflow.models.DAG attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.configure_s3_resources">configure_s3_resources() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.configure_s3_resources">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.configure_s3_resources">[2]</a> |
| </li> |
| <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.hooks.S3_hook.S3Hook.copy_object">copy_object() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.copy_object">[1]</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> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.create_bucket">(airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.create_bucket">[1]</a> |
| </li> |
| </ul></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.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.create_collection">create_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.create_collection">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.create_connection">create_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</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.azure_cosmos_hook.AzureCosmosDBHook.create_database">create_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.create_database">[1]</a> |
| |
| <ul> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.create_database">(airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| </ul></li> |
| <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> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint">create_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint_config">create_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint_config">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_endpoint_config">[2]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.create_instance">create_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_job">create_job() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_job">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.emr_hook.EmrHook.create_job_flow">create_job_flow() (airflow.contrib.hooks.emr_hook.EmrHook method)</a>, <a href="integration.html#airflow.contrib.hooks.emr_hook.EmrHook.create_job_flow">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_model">create_model() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_model">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_model">(airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_model">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_model">[2]</a> |
| </li> |
| </ul></li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.create_new_function">create_new_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.create_subscription">create_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.create_topic">create_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_training_job">create_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_training_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_training_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_transform_job">create_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_transform_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_transform_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_tuning_job">create_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_tuning_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.create_tuning_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_version">create_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.create_version">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.current_state">current_state() (airflow.models.TaskInstance method)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="D">D</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.BaseOperator.dag">dag (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.dag">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG">DAG (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagBag">DagBag (class in airflow.models)</a> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook">DatadogHook (class in airflow.contrib.hooks.datadog_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.datadog_sensor.DatadogSensor">DatadogSensor (class in airflow.contrib.sensors.datadog_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook">DataFlowHook (class in airflow.contrib.hooks.gcp_dataflow_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator">DataFlowJavaOperator (class in airflow.contrib.operators.dataflow_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator">DataFlowPythonOperator (class in airflow.contrib.operators.dataflow_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator">DataflowTemplateOperator (class in airflow.contrib.operators.dataflow_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator">DataprocClusterCreateOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator">[1]</a> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook">DataProcHook (class in airflow.contrib.hooks.gcp_dataproc_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcPigOperator">DataProcPigOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcPigOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator">DataProcPySparkOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcSparkOperator">DataProcSparkOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcSparkOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator">DataProcSparkSqlOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateBaseOperator">DataprocWorkflowTemplateBaseOperator (class in airflow.contrib.operators.dataproc_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateInlineOperator">DataprocWorkflowTemplateInstantiateInlineOperator (class in airflow.contrib.operators.dataproc_operator)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateInstantiateInlineOperator">[1]</a> |
| </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> |
| <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> |
| <li><a href="code.html#airflow.contrib.sensors.weekday_sensor.DayOfWeekSensor">DayOfWeekSensor (class in airflow.contrib.sensors.weekday_sensor)</a> |
| </li> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.deactivate_unknown_dags">deactivate_unknown_dags() (airflow.models.DAG static method)</a> |
| </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> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_collection">delete_collection() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_collection">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.delete_connection">delete_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_database">delete_database() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_database">[1]</a> |
| |
| <ul> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.delete_database">(airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.delete_directory">delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.delete_directory">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_document">delete_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.delete_document">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.delete_file">delete_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.delete_file">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.delete_file">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.delete_file">[1]</a> |
| </li> |
| </ul></li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.delete_function">delete_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.delete_instance">delete_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.delete_objects">delete_objects() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.delete_objects">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.delete_operation">delete_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.delete_operation">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.delete_subscription">delete_subscription() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.delete_topic">delete_topic() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.delete_version">delete_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.delete_version">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.deps">deps (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.deps">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.sensors.base_sensor_operator.BaseSensorOperator.deps">(airflow.sensors.base_sensor_operator.BaseSensorOperator attribute)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.describe_cluster_snapshots">describe_cluster_snapshots() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.describe_cluster_snapshots">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.describe_directory">describe_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.describe_directory">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint">describe_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint_config">describe_endpoint_config() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint_config">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_endpoint_config">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_model">describe_model() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_model">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_model">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.salesforce_hook.SalesforceHook.describe_object">describe_object() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job">describe_training_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job_with_log">describe_training_job_with_log() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job_with_log">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_training_job_with_log">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_transform_job">describe_transform_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_transform_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_transform_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_tuning_job">describe_tuning_job() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_tuning_job">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_tuning_job">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.discord_webhook_hook.DiscordWebhookHook">DiscordWebhookHook (class in airflow.contrib.hooks.discord_webhook_hook)</a> |
| </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.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.does_collection_exist">does_collection_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.does_collection_exist">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.does_database_exist">does_database_exist() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.does_database_exist">[1]</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.contrib.hooks.imap_hook.ImapHook.download_mail_attachments">download_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method)</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> |
| </li> |
| <li><a href="code.html#airflow.operators.dummy_operator.DummyOperator">DummyOperator (class in airflow.operators.dummy_operator)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="E">E</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.ecs_operator.ECSOperator">ECSOperator (class in airflow.contrib.operators.ecs_operator)</a>, <a href="integration.html#airflow.contrib.operators.ecs_operator.ECSOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.email_operator.EmailOperator">EmailOperator (class in airflow.operators.email_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator">EmrAddStepsOperator (class in airflow.contrib.operators.emr_add_steps_operator)</a>, <a href="integration.html#airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor">EmrBaseSensor (class in airflow.contrib.sensors.emr_base_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator">EmrCreateJobFlowOperator (class in airflow.contrib.operators.emr_create_job_flow_operator)</a>, <a href="integration.html#airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.emr_hook.EmrHook">EmrHook (class in airflow.contrib.hooks.emr_hook)</a>, <a href="integration.html#airflow.contrib.hooks.emr_hook.EmrHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.emr_job_flow_sensor.EmrJobFlowSensor">EmrJobFlowSensor (class in airflow.contrib.sensors.emr_job_flow_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.emr_step_sensor.EmrStepSensor">EmrStepSensor (class in airflow.contrib.sensors.emr_step_sensor)</a> |
| </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.kubernetes_executor.KubernetesExecutor.end">end() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.end">(airflow.contrib.executors.mesos_executor.MesosExecutor method)</a> |
| </li> |
| <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> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook.execute">(airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator.execute">(airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator.execute">(airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataFlowPythonOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator.execute">(airflow.contrib.operators.discord_webhook_operator.DiscordWebhookOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator method)</a>, <a href="integration.html#airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator.execute">[1]</a> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_sql_operator.SparkSqlOperator.execute">(airflow.contrib.operators.spark_sql_operator.SparkSqlOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator.execute">(airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sqoop_operator.SqoopOperator.execute">(airflow.contrib.operators.sqoop_operator.SqoopOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor.execute">(airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.execute">(airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.bash_operator.BashOperator.execute">(airflow.operators.bash_operator.BashOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.slack_operator.SlackAPIOperator.execute">(airflow.operators.slack_operator.SlackAPIOperator method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.executors.kubernetes_executor.KubernetesExecutor.execute_async">execute_async() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.execute_async">(airflow.contrib.executors.mesos_executor.MesosExecutor method)</a> |
| </li> |
| <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.aws_hook.AwsHook.expand_role">expand_role() (airflow.contrib.hooks.aws_hook.AwsHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.export_instance">export_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.export_to_storage_bucket">export_to_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.export_to_storage_bucket">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.external_task_sensor.ExternalTaskSensor">ExternalTaskSensor (class in airflow.sensors.external_task_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.models.Connection.extra_dejson">extra_dejson (airflow.models.Connection attribute)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="F">F</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_api_base_hook.GoogleCloudBaseHook.fallback_to_default_project_id">fallback_to_default_project_id() (airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook static method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook.fallback_to_default_project_id">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.filepath">filepath (airflow.models.DAG attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.file_sensor.FileSensor">FileSensor (class in airflow.contrib.sensors.file_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator">FileToGoogleCloudStorageOperator (class in airflow.contrib.operators.file_to_gcs)</a>, <a href="integration.html#airflow.contrib.operators.file_to_gcs.FileToGoogleCloudStorageOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.file_to_wasb.FileToWasbOperator">FileToWasbOperator (class in airflow.contrib.operators.file_to_wasb)</a>, <a href="integration.html#airflow.contrib.operators.file_to_wasb.FileToWasbOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.hdfs_sensor.HdfsSensor.filter_for_filesize">filter_for_filesize() (airflow.sensors.hdfs_sensor.HdfsSensor static method)</a> |
| </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.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.TaskReschedule.find_for_task_instance">find_for_task_instance() (airflow.models.TaskReschedule static method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.folder">folder (airflow.models.DAG attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.following_schedule">following_schedule() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.free_reserved_port">free_reserved_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.fs_hook.FSHook">FSHook (class in airflow.contrib.hooks.fs_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook">FTPHook (class in airflow.contrib.hooks.ftp_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.ftp_sensor.FTPSensor">FTPSensor (class in airflow.contrib.sensors.ftp_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPSHook">FTPSHook (class in airflow.contrib.hooks.ftp_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.ftp_sensor.FTPSSensor">FTPSSensor (class in airflow.contrib.sensors.ftp_sensor)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="G">G</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceBaseOperator">GceBaseOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook">GceHook (class in airflow.contrib.hooks.gcp_compute_hook)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceGroupManagerUpdateTemplateOperator">GceInstanceGroupManagerUpdateTemplateOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator">GceInstanceStartOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator">GceInstanceStopOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceTemplateCopyOperator">GceInstanceTemplateCopyOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator">GceSetMachineTypeOperator (class in airflow.contrib.operators.gcp_compute_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator">GcfFunctionDeleteOperator (class in airflow.contrib.operators.gcp_function_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator">GcfFunctionDeployOperator (class in airflow.contrib.operators.gcp_function_operator)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook">GcfHook (class in airflow.contrib.hooks.gcp_function_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook">GCPTransferServiceHook (class in airflow.contrib.hooks.gcp_transfer_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.generate_command">generate_command() (airflow.models.TaskInstance static method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.generic_transfer.GenericTransfer">GenericTransfer (class in airflow.operators.generic_transfer)</a> |
| </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.contrib.hooks.salesforce_hook.SalesforceHook.get_available_fields">get_available_fields() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </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.mongo_hook.MongoHook.get_collection">get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook.get_conn">get_conn() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook.get_conn">(airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook.get_conn">(airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_conn">(airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_conn">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.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> |
| </li> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPSHook.get_conn">(airflow.contrib.hooks.ftp_hook.FTPSHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.get_conn">(airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook.get_conn">(airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_dataflow_hook.DataFlowHook.get_conn">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook.get_conn">(airflow.contrib.hooks.gcp_dataproc_hook.DataProcHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.get_conn">(airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.get_conn">(airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.get_conn">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.get_conn">(airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.get_conn">(airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook.get_conn">(airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_transfer_hook.GCPTransferServiceHook.get_conn">[1]</a> |
| </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.sagemaker_hook.SageMakerHook.get_conn">(airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.get_conn">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.get_conn">[2]</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.ssh_hook.SSHHook.get_conn">(airflow.contrib.hooks.ssh_hook.SSHHook 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.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.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> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.hooks.hive_hooks.get_context_from_env_var">get_context_from_env_var() (in module airflow.hooks.hive_hooks)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_crc32c">get_crc32c() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.get_crc32c">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_hook.AwsHook.get_credentials">get_credentials() (airflow.contrib.hooks.aws_hook.AwsHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_cursor">get_cursor() (airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagBag.get_dag">get_dag() (airflow.models.DagBag method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.DagRun.get_dag">(airflow.models.DagRun method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.models.DAG.get_dagrun">get_dagrun() (airflow.models.DAG method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.TaskInstance.get_dagrun">(airflow.models.TaskInstance method)</a> |
| </li> |
| </ul></li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.get_database">get_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.get_database_hook">get_database_hook() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</a> |
| </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.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_document">get_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_document">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_documents">get_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.get_documents">[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.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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_first">get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_first">(airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| </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> |
| <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> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.get_function">get_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor.get_hook">get_hook() (airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.get_instance">get_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.get_instance_group_manager">get_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.get_instance_template">get_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.get_last_dagrun">get_last_dagrun() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagRun.get_latest_runs">get_latest_runs() (airflow.models.DagRun class method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.qubole_hook.QuboleHook.get_log">get_log() (airflow.contrib.hooks.qubole_hook.QuboleHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.get_log_conn">get_log_conn() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.get_log_conn">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.get_log_conn">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.models.XCom.get_many">get_many() (airflow.models.XCom class method)</a> |
| </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.ftp_hook.FTPHook.get_mod_time">get_mod_time() (airflow.contrib.hooks.ftp_hook.FTPHook 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> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.get_num_task_instances">get_num_task_instances() (airflow.models.DAG static method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.salesforce_hook.SalesforceHook.get_object_from_salesforce">get_object_from_salesforce() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </li> |
| <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> |
| </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.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook.get_partitions">get_partitions() (airflow.contrib.hooks.aws_glue_catalog_hook.AwsGlueCatalogHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_partitions">(airflow.hooks.hive_hooks.HiveMetastoreHook method)</a> |
| </li> |
| </ul></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> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner.get_proxy_version">get_proxy_version() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook.get_query_results">get_query_results() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_records">get_records() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a> |
| |
| <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> |
| <li><a href="code.html#airflow.contrib.hooks.qubole_hook.QuboleHook.get_results">get_results() (airflow.contrib.hooks.qubole_hook.QuboleHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveServer2Hook.get_results">(airflow.hooks.hive_hooks.HiveServer2Hook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.models.DagRun.get_run">get_run() (airflow.models.DagRun static method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.get_run_dates">get_run_dates() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_service">get_service() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_service">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_hook.AwsHook.get_session">get_session() (airflow.contrib.hooks.aws_hook.AwsHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.get_size">get_size() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.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> |
| </ul></li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner.get_socket_path">get_socket_path() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.get_sqlproxy_runner">get_sqlproxy_runner() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</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> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.DagRun.get_task_instances">(airflow.models.DagRun method)</a> |
| </li> |
| </ul></li> |
| <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.ssh_hook.SSHHook.get_tunnel">get_tunnel() (airflow.contrib.hooks.ssh_hook.SSHHook 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.hooks.gcp_api_base_hook.GoogleCloudBaseHook">GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageBucketCreateAclEntryOperator">GoogleCloudStorageBucketCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator)</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator">GoogleCloudStorageDownloadOperator (class in airflow.contrib.operators.gcs_download_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook">GoogleCloudStorageHook (class in airflow.contrib.hooks.gcs_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator">GoogleCloudStorageListOperator (class in airflow.contrib.operators.gcs_list_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcs_acl_operator.GoogleCloudStorageObjectCreateAclEntryOperator">GoogleCloudStorageObjectCreateAclEntryOperator (class in airflow.contrib.operators.gcs_acl_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor">GoogleCloudStorageObjectSensor (class in airflow.contrib.sensors.gcs_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor">GoogleCloudStorageObjectUpdatedSensor (class in airflow.contrib.sensors.gcs_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor">GoogleCloudStoragePrefixSensor (class in airflow.contrib.sensors.gcs_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator">GoogleCloudStorageToBigQueryOperator (class in airflow.contrib.operators.gcs_to_bq)</a>, <a href="integration.html#airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator">GoogleCloudStorageToGoogleCloudStorageOperator (class in airflow.contrib.operators.gcs_to_gcs)</a>, <a href="integration.html#airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_gcs_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator">GoogleCloudStorageToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.gcs_to_gcs_transfer_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcs_to_gcs_transfer_operator.GoogleCloudStorageToGoogleCloudStorageTransferOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator">GoogleCloudStorageToS3Operator (class in airflow.contrib.operators.gcs_to_s3)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="H">H</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.DAG.handle_callback">handle_callback() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.has_dag">has_dag() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.has_dag">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.imap_hook.ImapHook.has_mail_attachment">has_mail_attachment() (airflow.contrib.hooks.imap_hook.ImapHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.hdfs_hook.HDFSHook">HDFSHook (class in airflow.hooks.hdfs_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.hdfs_sensor.HdfsSensor">HdfsSensor (class in airflow.sensors.hdfs_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder">HdfsSensorFolder (class in airflow.contrib.sensors.hdfs_sensor)</a> |
| </li> |
| <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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveCliHook">HiveCliHook (class in airflow.hooks.hive_hooks)</a> |
| </li> |
| <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> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="I">I</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.imap_hook.ImapHook">ImapHook (class in airflow.contrib.hooks.imap_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.import_from_storage_bucket">import_from_storage_bucket() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.import_from_storage_bucket">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.import_instance">import_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook.import_query">import_query() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)</a> |
| </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.gcs_hook.GoogleCloudStorageHook.insert_bucket_acl">insert_bucket_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.insert_bucket_acl">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.insert_documents">insert_documents() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.insert_documents">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.insert_instance_template">insert_instance_template() (airflow.contrib.hooks.gcp_compute_hook.GceHook 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.gcs_hook.GoogleCloudStorageHook.insert_object_acl">insert_object_acl() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.insert_object_acl">[1]</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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.presto_hook.PrestoHook.insert_rows">(airflow.hooks.presto_hook.PrestoHook method)</a> |
| </li> |
| </ul></li> |
| <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_fixed_time_schedule">is_fixed_time_schedule() (airflow.models.DAG 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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.is_updated_after">is_updated_after() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.is_updated_after">[1]</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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.jira_hook.JiraHook">JiraHook (class in airflow.contrib.hooks.jira_hook)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.operators.jira_operator.JiraOperator">JiraOperator (class in airflow.contrib.operators.jira_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.jira_sensor.JiraSensor">JiraSensor (class in airflow.contrib.sensors.jira_sensor)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="K">K</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.TaskInstance.key">key (airflow.models.TaskInstance attribute)</a> |
| </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> |
| <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> |
| <li><a href="code.html#airflow.models.KnownEvent">KnownEvent (class in airflow.models)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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.executors.kubernetes_executor.KubernetesExecutor">KubernetesExecutor (class in airflow.contrib.executors.kubernetes_executor)</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> |
| |
| <h2 id="L">L</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.DAG.latest_execution_date">latest_execution_date (airflow.models.DAG attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.latest_only_operator.LatestOnlyOperator">LatestOnlyOperator (class in airflow.operators.latest_only_operator)</a> |
| </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> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.list_directory">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.list_keys">list_keys() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.list_keys">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.list_prefixes">list_prefixes() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.list_prefixes">[1]</a> |
| </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> |
| <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.hooks.hive_hooks.HiveCliHook.load_df">load_df() (airflow.hooks.hive_hooks.HiveCliHook method)</a> |
| </li> |
| <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> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.load_file_obj">load_file_obj() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.load_file_obj">[1]</a> |
| </li> |
| <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> |
| <li><a href="code.html#airflow.executors.local_executor.LocalExecutor">LocalExecutor (class in airflow.executors.local_executor)</a> |
| </li> |
| <li><a href="code.html#airflow.models.Log">Log (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.log_stream">log_stream() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.log_stream">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.log_stream">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.lookup">lookup() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.lookup">[1]</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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.contrib.hooks.salesforce_hook.SalesforceHook.make_query">make_query() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </li> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator">MLEngineBatchPredictionOperator (class in airflow.contrib.operators.mlengine_operator)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook">MLEngineHook (class in airflow.contrib.hooks.gcp_mlengine_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook">[1]</a> |
| </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> |
| <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.contrib.hooks.sagemaker_hook.SageMakerHook.multi_stream_iter">multi_stream_iter() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.multi_stream_iter">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.multi_stream_iter">[2]</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>, <a href="integration.html#airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator">[1]</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> |
| |
| <h2 id="N">N</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <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> |
| <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.operators.aws_athena_operator.AWSAthenaOperator.on_kill">on_kill() (airflow.contrib.operators.aws_athena_operator.AWSAthenaOperator method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.BaseOperator.on_kill">(airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.on_kill">[1]</a> |
| </li> |
| </ul></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.contrib.hooks.openfaas_hook.OpenFaasHook">OpenFaasHook (class in airflow.contrib.hooks.openfaas_hook)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="P">P</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.patch_database">patch_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.patch_instance">patch_instance() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.patch_instance_group_manager">patch_instance_group_manager() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.pig_hook.PigCliHook">PigCliHook (class in airflow.hooks.pig_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.pig_operator.PigOperator">PigOperator (class in airflow.operators.pig_operator)</a> |
| </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.aws_athena_sensor.AthenaSensor.poke">poke() (airflow.contrib.sensors.aws_athena_sensor.AthenaSensor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor.poke">(airflow.contrib.sensors.aws_glue_catalog_partition_sensor.AwsGlueCatalogPartitionSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor.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> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor.poke">(airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor method)</a>, <a href="integration.html#airflow.contrib.sensors.azure_cosmos_sensor.AzureCosmosDocumentSensor.poke">[1]</a> |
| </li> |
| <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.cassandra_record_sensor.CassandraRecordSensor.poke">(airflow.contrib.sensors.cassandra_record_sensor.CassandraRecordSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor.poke">(airflow.contrib.sensors.cassandra_table_sensor.CassandraTableSensor 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.python_sensor.PythonSensor.poke">(airflow.contrib.sensors.python_sensor.PythonSensor 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.sagemaker_base_sensor.SageMakerBaseSensor.poke">(airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor 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.contrib.sensors.weekday_sensor.DayOfWeekSensor.poke">(airflow.contrib.sensors.weekday_sensor.DayOfWeekSensor 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.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.contrib.hooks.aws_athena_hook.AWSAthenaHook.poll_query_status">poll_query_status() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook.post_event">post_event() (airflow.contrib.hooks.datadog_hook.DatadogHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.post_execute">post_execute() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.post_execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook">PostgresHook (class in airflow.hooks.postgres_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.postgres_operator.PostgresOperator">PostgresOperator (class in airflow.operators.postgres_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator">PostgresToGoogleCloudStorageOperator (class in airflow.contrib.operators.postgres_to_gcs_operator)</a> |
| </li> |
| <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> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.operators.presto_check_operator.PrestoIntervalCheckOperator">PrestoIntervalCheckOperator (class in airflow.operators.presto_check_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.presto_to_mysql.PrestoToMySqlTransfer">PrestoToMySqlTransfer (class in airflow.operators.presto_to_mysql)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.presto_check_operator.PrestoValueCheckOperator">PrestoValueCheckOperator (class in airflow.operators.presto_check_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.previous_schedule">previous_schedule() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.previous_ti">previous_ti (airflow.models.TaskInstance attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagBag.process_file">process_file() (airflow.models.DagBag method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.publish">publish() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook">PubSubHook (class in airflow.contrib.hooks.gcp_pubsub_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubPublishOperator">PubSubPublishOperator (class in airflow.contrib.operators.pubsub_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor">PubSubPullSensor (class in airflow.contrib.sensors.pubsub_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator">PubSubSubscriptionCreateOperator (class in airflow.contrib.operators.pubsub_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator">PubSubSubscriptionDeleteOperator (class in airflow.contrib.operators.pubsub_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator">PubSubTopicCreateOperator (class in airflow.contrib.operators.pubsub_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator">PubSubTopicDeleteOperator (class in airflow.contrib.operators.pubsub_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook.pull">pull() (airflow.contrib.hooks.gcp_pubsub_hook.PubSubHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook.put_records">put_records() (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.PythonOperator">PythonOperator (class in airflow.operators.python_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.python_sensor.PythonSensor">PythonSensor (class in airflow.contrib.sensors.python_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.PythonVirtualenvOperator">PythonVirtualenvOperator (class in airflow.operators.python_operator)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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>, <a href="integration.html#airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.sensors.qubole_sensor.QuboleFileSensor">QuboleFileSensor (class in airflow.contrib.sensors.qubole_sensor)</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>, <a href="integration.html#airflow.contrib.operators.qubole_operator.QuboleOperator">[1]</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="integration.html#airflow.contrib.sensors.qubole_sensor.QubolePartitionSensor">QubolePartitionSensor (class in airflow.contrib.sensors.qubole_sensor)</a> |
| </li> |
| <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>, <a href="integration.html#airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator">[1]</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook">RedshiftHook (class in airflow.contrib.hooks.redshift_hook)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer">RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator)</a>, <a href="integration.html#airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagRun.refresh_from_db">refresh_from_db() (airflow.models.DagRun method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.TaskInstance.refresh_from_db">(airflow.models.TaskInstance method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.rename">rename() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.render_template">render_template() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.render_template">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.render_template_from_field">render_template_from_field() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.render_template_from_field">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.reserve_free_tcp_port">reserve_free_tcp_port() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.restore_from_cluster_snapshot">restore_from_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.restore_from_cluster_snapshot">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook.retrieve_connection">retrieve_connection() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlDatabaseHook method)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.retrieve_file">retrieve_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.retrieve_file">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.imap_hook.ImapHook.retrieve_mail_attachments">retrieve_mail_attachments() (airflow.contrib.hooks.imap_hook.ImapHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.rewrite">rewrite() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.rewrite">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.rollback">rollback() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.rollback">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.run">run() (airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.http_hook.HttpHook.run">(airflow.hooks.http_hook.HttpHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.run">(airflow.hooks.presto_hook.PrestoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.run">(airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.run">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.run">(airflow.models.DAG method)</a> |
| </li> |
| </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.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.databricks_hook.DatabricksHook.run_now">run_now() (airflow.contrib.hooks.databricks_hook.DatabricksHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook.run_query">run_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.run_query">(airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.run_query">[1]</a> |
| </li> |
| <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> |
| |
| <h2 id="S">S</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.operators.s3_file_transform_operator.S3FileTransformOperator">S3FileTransformOperator (class in airflow.operators.s3_file_transform_operator)</a>, <a href="integration.html#airflow.operators.s3_file_transform_operator.S3FileTransformOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook">S3Hook (class in airflow.hooks.S3_hook)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.s3_key_sensor.S3KeySensor">S3KeySensor (class in airflow.sensors.s3_key_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.s3_list_operator.S3ListOperator">S3ListOperator (class in airflow.contrib.operators.s3_list_operator)</a>, <a href="integration.html#airflow.contrib.operators.s3_list_operator.S3ListOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.s3_prefix_sensor.S3PrefixSensor">S3PrefixSensor (class in airflow.sensors.s3_prefix_sensor)</a> |
| </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.contrib.operators.s3_to_gcs_transfer_operator.S3ToGoogleCloudStorageTransferOperator">S3ToGoogleCloudStorageTransferOperator (class in airflow.contrib.operators.s3_to_gcs_transfer_operator)</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.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator">SageMakerBaseOperator (class in airflow.contrib.operators.sagemaker_base_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sagemaker_base_sensor.SageMakerBaseSensor">SageMakerBaseSensor (class in airflow.contrib.sensors.sagemaker_base_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator">SageMakerEndpointConfigOperator (class in airflow.contrib.operators.sagemaker_endpoint_config_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator">SageMakerEndpointOperator (class in airflow.contrib.operators.sagemaker_endpoint_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sagemaker_endpoint_sensor.SageMakerEndpointSensor">SageMakerEndpointSensor (class in airflow.contrib.sensors.sagemaker_endpoint_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook">SageMakerHook (class in airflow.contrib.hooks.sagemaker_hook)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator">SageMakerModelOperator (class in airflow.contrib.operators.sagemaker_model_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator">SageMakerTrainingOperator (class in airflow.contrib.operators.sagemaker_training_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sagemaker_training_sensor.SageMakerTrainingSensor">SageMakerTrainingSensor (class in airflow.contrib.sensors.sagemaker_training_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator">SageMakerTransformOperator (class in airflow.contrib.operators.sagemaker_transform_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sagemaker_transform_sensor.SageMakerTransformSensor">SageMakerTransformSensor (class in airflow.contrib.sensors.sagemaker_transform_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator">SageMakerTuningOperator (class in airflow.contrib.operators.sagemaker_tuning_operator)</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator">[1]</a>, <a href="integration.html#airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator">[2]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sagemaker_tuning_sensor.SageMakerTuningSensor">SageMakerTuningSensor (class in airflow.contrib.sensors.sagemaker_tuning_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.salesforce_hook.SalesforceHook">SalesforceHook (class in airflow.contrib.hooks.salesforce_hook)</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.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> |
| </li> |
| <li><a href="code.html#airflow.executors.sequential_executor.SequentialExecutor">SequentialExecutor (class in airflow.executors.sequential_executor)</a> |
| </li> |
| <li><a href="code.html#airflow.models.XCom.set">set() (airflow.models.XCom class method)</a> |
| </li> |
| <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.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="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.set_machine_type">set_machine_type() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.sftp_sensor.SFTPSensor">SFTPSensor (class in airflow.contrib.sensors.sftp_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.ShortCircuitOperator">ShortCircuitOperator (class in airflow.operators.python_operator)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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.contrib.hooks.salesforce_hook.SalesforceHook.sign_in">sign_in() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.http_operator.SimpleHttpOperator">SimpleHttpOperator (class in airflow.operators.http_operator)</a> |
| </li> |
| <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> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.slack_webhook_hook.SlackWebhookHook">SlackWebhookHook (class in airflow.contrib.hooks.slack_webhook_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.slack_webhook_operator.SlackWebhookOperator">SlackWebhookOperator (class in airflow.contrib.operators.slack_webhook_operator)</a> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.spark_sql_hook.SparkSqlHook">SparkSqlHook (class in airflow.contrib.hooks.spark_sql_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_sql_operator.SparkSqlOperator">SparkSqlOperator (class in airflow.contrib.operators.spark_sql_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook">SparkSubmitHook (class in airflow.contrib.hooks.spark_submit_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator">SparkSubmitOperator (class in airflow.contrib.operators.spark_submit_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.sqlite_hook.SqliteHook">SqliteHook (class in airflow.hooks.sqlite_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.sqlite_operator.SqliteOperator">SqliteOperator (class in airflow.operators.sqlite_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.sql_sensor.SqlSensor">SqlSensor (class in airflow.sensors.sql_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook">SqoopHook (class in airflow.contrib.hooks.sqoop_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sqoop_operator.SqoopOperator">SqoopOperator (class in airflow.contrib.operators.sqoop_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ssh_hook.SSHHook">SSHHook (class in airflow.contrib.hooks.ssh_hook)</a> |
| </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.kubernetes_executor.KubernetesExecutor.start">start() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.start">(airflow.contrib.executors.mesos_executor.MesosExecutor method)</a> |
| </li> |
| <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="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.start_instance">start_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner.start_proxy">start_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_compute_hook.GceHook.stop_instance">stop_instance() (airflow.contrib.hooks.gcp_compute_hook.GceHook method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner.stop_proxy">stop_proxy() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlProxyRunner method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook.stop_query">stop_query() (airflow.contrib.hooks.aws_athena_hook.AWSAthenaHook method)</a> |
| </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> |
| <li><a href="code.html#airflow.contrib.hooks.sftp_hook.SFTPHook.store_file">(airflow.contrib.hooks.sftp_hook.SFTPHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.models.DAG.sub_dag">sub_dag() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.subdag_operator.SubDagOperator">SubDagOperator (class in airflow.operators.subdag_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.subdags">subdags (airflow.models.DAG attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook.submit">submit() (airflow.contrib.hooks.spark_submit_hook.SparkSubmitHook method)</a> |
| </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.kubernetes_executor.KubernetesExecutor.sync">sync() (airflow.contrib.executors.kubernetes_executor.KubernetesExecutor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.executors.mesos_executor.MesosExecutor.sync">(airflow.contrib.executors.mesos_executor.MesosExecutor method)</a> |
| </li> |
| <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> |
| </tr></table> |
| |
| <h2 id="T">T</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.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.contrib.hooks.cassandra_hook.CassandraHook.table_exists">(airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a> |
| </li> |
| <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.contrib.hooks.sagemaker_hook.SageMakerHook.tar_and_s3_upload">tar_and_s3_upload() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.tar_and_s3_upload">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.tar_and_s3_upload">[2]</a> |
| </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.TaskReschedule">TaskReschedule (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.ftp_sensor.FTPSensor.template_fields">template_fields (airflow.contrib.sensors.ftp_sensor.FTPSensor attribute)</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.hooks.hive_hooks.HiveCliHook.test_hql">test_hql() (airflow.hooks.hive_hooks.HiveCliHook method)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.sensors.time_delta_sensor.TimeDeltaSensor">TimeDeltaSensor (class in airflow.sensors.time_delta_sensor)</a> |
| </li> |
| <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.hooks.hive_hooks.HiveServer2Hook.to_csv">to_csv() (airflow.hooks.hive_hooks.HiveServer2Hook method)</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 static 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> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.try_number">try_number (airflow.models.TaskInstance attribute)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator.type_map">type_map() (airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator class method)</a>, <a href="integration.html#airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator.type_map">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator.type_map">(airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator class method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| </tr></table> |
| |
| <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.contrib.hooks.sagemaker_hook.SageMakerHook.update_endpoint">update_endpoint() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.update_endpoint">[1]</a>, <a href="integration.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.update_endpoint">[2]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.update_function">update_function() (airflow.contrib.hooks.gcp_function_hook.GcfHook 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.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="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.upload_function_zip">upload_function_zip() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.upsert_document">upsert_document() (airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_cosmos_hook.AzureCosmosDBHook.upsert_document">[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> |
| |
| <h2 id="V">V</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <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> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.hooks.vertica_hook.VerticaHook">VerticaHook (class in airflow.contrib.hooks.vertica_hook)</a> |
| </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.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> |
| </li> |
| <li><a href="integration.html#airflow.contrib.sensors.wasb_sensor.WasbPrefixSensor">WasbPrefixSensor (class in airflow.contrib.sensors.wasb_sensor)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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> |
| <li><a href="code.html#airflow.contrib.hooks.salesforce_hook.SalesforceHook.write_object_to_file">write_object_to_file() (airflow.contrib.hooks.salesforce_hook.SalesforceHook method)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="X">X</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.XCom">XCom (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.xcom_pull">xcom_pull() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.xcom_pull">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.TaskInstance.xcom_pull">(airflow.models.TaskInstance method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.BaseOperator.xcom_push">xcom_push() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.xcom_push">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.TaskInstance.xcom_push">(airflow.models.TaskInstance method)</a> |
| </li> |
| </ul></li> |
| </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> |
| <footer> |
| |
| |
| <hr/> |
| |
| <div role="contentinfo"> |
| <p> |
| |
| </p> |
| </div> |
| Built with <a href="http://sphinx-doc.org/">Sphinx</a> using a <a href="https://github.com/rtfd/sphinx_rtd_theme">theme</a> provided by <a href="https://readthedocs.org">Read the Docs</a>. |
| |
| </footer> |
| |
| </div> |
| </div> |
| |
| </section> |
| |
| </div> |
| |
| |
| |
| |
| |
| |
| |
| <script type="text/javascript" id="documentation_options" data-url_root="./" src="_static/documentation_options.js"></script> |
| <script type="text/javascript" src="_static/jquery.js"></script> |
| <script type="text/javascript" src="_static/underscore.js"></script> |
| <script type="text/javascript" src="_static/doctools.js"></script> |
| <script type="text/javascript" src="_static/language_data.js"></script> |
| |
| |
| |
| |
| <script type="text/javascript" src="_static/js/theme.js"></script> |
| |
| <script type="text/javascript"> |
| jQuery(function () { |
| SphinxRtdTheme.Navigation.enable(true); |
| }); |
| </script> |
| |
| </body> |
| </html> |
