| |
| |
| |
| <!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> |
| |
| </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 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="lineage.html">Lineage</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.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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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.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_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_data_lake_hook.AzureDataLakeHook">AzureDataLakeHook (class in airflow.contrib.hooks.azure_data_lake_hook)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook">AzureFileShareHook (class in airflow.contrib.hooks.azure_fileshare_hook)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook">[1]</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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.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> |
| <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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator">BigQueryTableDeleteOperator (class in airflow.contrib.operators.bigquery_table_delete_operator)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor">BigQueryTableSensor (class in airflow.contrib.sensors.bigquery_sensor)</a> |
| </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.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator.build_job">build_job() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.bulk_dump">bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.bulk_dump">(airflow.hooks.mysql_hook.MySqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.bulk_dump">(airflow.hooks.postgres_hook.PostgresHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.bulk_insert_rows">bulk_insert_rows() (airflow.hooks.oracle_hook.OracleHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.bulk_load">bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| |
| <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_sensor.CassandraRecordSensor">CassandraRecordSensor (class in airflow.contrib.sensors.cassandra_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.hooks.hive_hooks.HiveMetastoreHook.check_for_partition">check_for_partition() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.webhdfs_hook.WebHDFSHook.check_for_path">check_for_path() (airflow.hooks.webhdfs_hook.WebHDFSHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_prefix">check_for_prefix() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.check_for_prefix">[1]</a> |
| |
| <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.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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.check_status">check_status() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook method)</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> |
| </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> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.operators.check_operator.CheckOperator">CheckOperator (class in airflow.operators.check_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.clear">clear() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.clear">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.models.DAG.clear">(airflow.models.DAG method)</a> |
| </li> |
| </ul></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.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.CloudSqlInstancePatchOperator">CloudSqlInstancePatchOperator (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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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">concurrency (airflow.models.DAG attribute)</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> |
| </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.gcp_container_hook.GKEClusterHook.create_cluster">create_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.create_cluster">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.create_cluster_snapshot">create_cluster_snapshot() (airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.create_cluster_snapshot">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.create_dagrun">create_dagrun() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.create_database">create_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </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> |
| </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> |
| </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> |
| </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> |
| </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> |
| </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> |
| </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.DAG.dag_id">dag_id (airflow.models.DAG attribute)</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.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.gcp_container_hook.GKEClusterHook.delete_cluster">delete_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.delete_cluster">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">(airflow.contrib.hooks.redshift_hook.RedshiftHook method)</a>, <a href="integration.html#airflow.contrib.hooks.redshift_hook.RedshiftHook.delete_cluster">[1]</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="integration.html#airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook.delete_database">delete_database() (airflow.contrib.hooks.gcp_sql_hook.CloudSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.delete_directory">delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <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.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> |
| </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> |
| </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> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sagemaker_hook.SageMakerHook.describe_model">describe_model() (airflow.contrib.hooks.sagemaker_hook.SageMakerHook 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> |
| </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> |
| </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> |
| </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> |
| </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.hooks.docker_hook.DockerHook">DockerHook (class in airflow.hooks.docker_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.docker_operator.DockerOperator">DockerOperator (class in airflow.operators.docker_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.download">download() (airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcs_hook.GoogleCloudStorageHook.download">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.download_file">download_file() (airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_data_lake_hook.AzureDataLakeHook.download_file">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.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.executors.celery_executor.CeleryExecutor.end">end() (airflow.executors.celery_executor.CeleryExecutor method)</a> |
| |
| <ul> |
| <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.awsbatch_operator.AWSBatchOperator.execute">(airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method)</a>, <a href="integration.html#airflow.contrib.operators.awsbatch_operator.AWSBatchOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator.execute">(airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_get_data.BigQueryGetDataOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator.execute">(airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateEmptyTableOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator.execute">(airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryCreateExternalTableOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator.execute">(airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryDeleteDatasetOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator.execute">(airflow.contrib.operators.bigquery_operator.BigQueryOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator.execute">(airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator.execute">(airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_to_bigquery.BigQueryToBigQueryOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator.execute">(airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_to_gcs.BigQueryToCloudStorageOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.cassandra_to_gcs.CassandraToGoogleCloudStorageOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator.execute">(airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator method)</a>, <a href="integration.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator.execute">(airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataFlowJavaOperator.execute">[1]</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.dataflow_operator.DataflowTemplateOperator.execute">(airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataflow_operator.DataflowTemplateOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcHadoopOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcHiveOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcHiveOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcHiveOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcPigOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcPigOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcPigOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcPySparkOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcSparkOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcSparkOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcSparkOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator.execute">(airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataProcSparkSqlOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator.execute">(airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterCreateOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator.execute">(airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterDeleteOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator.execute">(airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator method)</a>, <a href="integration.html#airflow.contrib.operators.dataproc_operator.DataprocClusterScaleOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateBaseOperator.execute">(airflow.contrib.operators.dataproc_operator.DataprocWorkflowTemplateBaseOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator.execute">(airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator method)</a>, <a href="integration.html#airflow.contrib.operators.datastore_export_operator.DatastoreExportOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator.execute">(airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator method)</a>, <a href="integration.html#airflow.contrib.operators.datastore_import_operator.DatastoreImportOperator.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.druid_operator.DruidOperator.execute">(airflow.contrib.operators.druid_operator.DruidOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.ecs_operator.ECSOperator.execute">(airflow.contrib.operators.ecs_operator.ECSOperator method)</a>, <a href="integration.html#airflow.contrib.operators.ecs_operator.ECSOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator.execute">(airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator method)</a>, <a href="integration.html#airflow.contrib.operators.emr_add_steps_operator.EmrAddStepsOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator.execute">(airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator method)</a>, <a href="integration.html#airflow.contrib.operators.emr_create_job_flow_operator.EmrCreateJobFlowOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator.execute">(airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator method)</a>, <a href="integration.html#airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator.execute">[1]</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="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator.execute">(airflow.contrib.operators.gcp_compute_operator.GceInstanceStartOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator.execute">(airflow.contrib.operators.gcp_compute_operator.GceInstanceStopOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator.execute">(airflow.contrib.operators.gcp_compute_operator.GceSetMachineTypeOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator.execute">(airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator.execute">(airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator.execute">[1]</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator.execute">(airflow.contrib.operators.gcp_function_operator.GcfFunctionDeleteOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator.execute">(airflow.contrib.operators.gcp_function_operator.GcfFunctionDeployOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceCreateOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseCreateOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabaseDeleteOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDatabasePatchOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstanceDeleteOperator method)</a> |
| </li> |
| <li><a href="integration.html#airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator.execute">(airflow.contrib.operators.gcp_sql_operator.CloudSqlInstancePatchOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator.execute">(airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcs_download_operator.GoogleCloudStorageDownloadOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator.execute">(airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcs_list_operator.GoogleCloudStorageListOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator.execute">(airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator.execute">(airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcs_to_bq.GoogleCloudStorageToBigQueryOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator method)</a>, <a href="integration.html#airflow.contrib.operators.gcs_to_gcs.GoogleCloudStorageToGoogleCloudStorageOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator.execute">(airflow.contrib.operators.gcs_to_s3.GoogleCloudStorageToS3Operator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.hipchat_operator.HipChatAPIOperator.execute">(airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator.execute">(airflow.contrib.operators.hive_to_dynamodb.HiveToDynamoDBTransferOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator.execute">(airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.jira_operator.JiraOperator.execute">(airflow.contrib.operators.jira_operator.JiraOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator.execute">(airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator method)</a>, <a href="kubernetes.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator.execute">(airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator method)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineBatchPredictionOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineModelOperator.execute">(airflow.contrib.operators.mlengine_operator.MLEngineModelOperator method)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineModelOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator.execute">(airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator method)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineTrainingOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator.execute">(airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator method)</a>, <a href="integration.html#airflow.contrib.operators.mlengine_operator.MLEngineVersionOperator.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.mysql_to_gcs.MySqlToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.postgres_to_gcs_operator.PostgresToGoogleCloudStorageOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubPublishOperator.execute">(airflow.contrib.operators.pubsub_operator.PubSubPublishOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator.execute">(airflow.contrib.operators.pubsub_operator.PubSubSubscriptionCreateOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator.execute">(airflow.contrib.operators.pubsub_operator.PubSubSubscriptionDeleteOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator.execute">(airflow.contrib.operators.pubsub_operator.PubSubTopicCreateOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator.execute">(airflow.contrib.operators.pubsub_operator.PubSubTopicDeleteOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator.execute">(airflow.contrib.operators.qubole_check_operator.QuboleCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator.execute">(airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.qubole_operator.QuboleOperator.execute">(airflow.contrib.operators.qubole_operator.QuboleOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.s3_list_operator.S3ListOperator.execute">(airflow.contrib.operators.s3_list_operator.S3ListOperator method)</a>, <a href="integration.html#airflow.contrib.operators.s3_list_operator.S3ListOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator.execute">(airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator method)</a>, <a href="integration.html#airflow.contrib.operators.s3_to_gcs_operator.S3ToGoogleCloudStorageOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator.execute">(airflow.contrib.operators.sagemaker_base_operator.SageMakerBaseOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator.execute">(airflow.contrib.operators.sagemaker_endpoint_config_operator.SageMakerEndpointConfigOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator.execute">(airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator.execute">(airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator.execute">(airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator.execute">(airflow.contrib.operators.sagemaker_transform_operator.SageMakerTransformOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator.execute">(airflow.contrib.operators.sagemaker_tuning_operator.SageMakerTuningOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator.execute">(airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sftp_operator.SFTPOperator.execute">(airflow.contrib.operators.sftp_operator.SFTPOperator 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.snowflake_operator.SnowflakeOperator.execute">(airflow.contrib.operators.snowflake_operator.SnowflakeOperator 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.operators.ssh_operator.SSHOperator.execute">(airflow.contrib.operators.ssh_operator.SSHOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.vertica_operator.VerticaOperator.execute">(airflow.contrib.operators.vertica_operator.VerticaOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer.execute">(airflow.contrib.operators.vertica_to_hive.VerticaToHiveTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.winrm_operator.WinRMOperator.execute">(airflow.contrib.operators.winrm_operator.WinRMOperator 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.check_operator.CheckOperator.execute">(airflow.operators.check_operator.CheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.check_operator.IntervalCheckOperator.execute">(airflow.operators.check_operator.IntervalCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.check_operator.ValueCheckOperator.execute">(airflow.operators.check_operator.ValueCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.dagrun_operator.TriggerDagRunOperator.execute">(airflow.operators.dagrun_operator.TriggerDagRunOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.docker_operator.DockerOperator.execute">(airflow.operators.docker_operator.DockerOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.druid_check_operator.DruidCheckOperator.execute">(airflow.operators.druid_check_operator.DruidCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.dummy_operator.DummyOperator.execute">(airflow.operators.dummy_operator.DummyOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.email_operator.EmailOperator.execute">(airflow.operators.email_operator.EmailOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.generic_transfer.GenericTransfer.execute">(airflow.operators.generic_transfer.GenericTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_operator.HiveOperator.execute">(airflow.operators.hive_operator.HiveOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_stats_operator.HiveStatsCollectionOperator.execute">(airflow.operators.hive_stats_operator.HiveStatsCollectionOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_to_druid.HiveToDruidTransfer.execute">(airflow.operators.hive_to_druid.HiveToDruidTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_to_mysql.HiveToMySqlTransfer.execute">(airflow.operators.hive_to_mysql.HiveToMySqlTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_to_samba_operator.Hive2SambaOperator.execute">(airflow.operators.hive_to_samba_operator.Hive2SambaOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.http_operator.SimpleHttpOperator.execute">(airflow.operators.http_operator.SimpleHttpOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.jdbc_operator.JdbcOperator.execute">(airflow.operators.jdbc_operator.JdbcOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.latest_only_operator.LatestOnlyOperator.execute">(airflow.operators.latest_only_operator.LatestOnlyOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mssql_operator.MsSqlOperator.execute">(airflow.operators.mssql_operator.MsSqlOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mssql_to_hive.MsSqlToHiveTransfer.execute">(airflow.operators.mssql_to_hive.MsSqlToHiveTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mysql_operator.MySqlOperator.execute">(airflow.operators.mysql_operator.MySqlOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mysql_to_hive.MySqlToHiveTransfer.execute">(airflow.operators.mysql_to_hive.MySqlToHiveTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.oracle_operator.OracleOperator.execute">(airflow.operators.oracle_operator.OracleOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.pig_operator.PigOperator.execute">(airflow.operators.pig_operator.PigOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.postgres_operator.PostgresOperator.execute">(airflow.operators.postgres_operator.PostgresOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.presto_to_mysql.PrestoToMySqlTransfer.execute">(airflow.operators.presto_to_mysql.PrestoToMySqlTransfer method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.BranchPythonOperator.execute">(airflow.operators.python_operator.BranchPythonOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.PythonOperator.execute">(airflow.operators.python_operator.PythonOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.python_operator.ShortCircuitOperator.execute">(airflow.operators.python_operator.ShortCircuitOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer.execute">(airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer method)</a>, <a href="integration.html#airflow.operators.redshift_to_s3_operator.RedshiftToS3Transfer.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.s3_file_transform_operator.S3FileTransformOperator.execute">(airflow.operators.s3_file_transform_operator.S3FileTransformOperator method)</a>, <a href="integration.html#airflow.operators.s3_file_transform_operator.S3FileTransformOperator.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.s3_to_hive_operator.S3ToHiveTransfer.execute">(airflow.operators.s3_to_hive_operator.S3ToHiveTransfer method)</a>, <a href="integration.html#airflow.operators.s3_to_hive_operator.S3ToHiveTransfer.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer.execute">(airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer method)</a>, <a href="integration.html#airflow.operators.s3_to_redshift_operator.S3ToRedshiftTransfer.execute">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.operators.slack_operator.SlackAPIOperator.execute">(airflow.operators.slack_operator.SlackAPIOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.sqlite_operator.SqliteOperator.execute">(airflow.operators.sqlite_operator.SqliteOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.subdag_operator.SubDagOperator.execute">(airflow.operators.subdag_operator.SubDagOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.base_sensor_operator.BaseSensorOperator.execute">(airflow.sensors.base_sensor_operator.BaseSensorOperator method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.executors.celery_executor.CeleryExecutor.execute_async">execute_async() (airflow.executors.celery_executor.CeleryExecutor method)</a> |
| |
| <ul> |
| <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="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.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.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="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> |
| <li><a href="code.html#airflow.models.DAG.full_filepath">full_filepath (airflow.models.DAG attribute)</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.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.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.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.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.gcp_container_hook.GKEClusterHook.get_cluster">get_cluster() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_cluster">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.get_collection">get_collection() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook.get_conn">get_conn() (airflow.contrib.hooks.aws_firehose_hook.AwsFirehoseHook method)</a> |
| |
| <ul> |
| <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="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.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> |
| </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.jdbc_hook.JdbcHook.get_conn">(airflow.hooks.jdbc_hook.JdbcHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.mssql_hook.MsSqlHook.get_conn">(airflow.hooks.mssql_hook.MsSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.get_conn">(airflow.hooks.mysql_hook.MySqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.get_conn">(airflow.hooks.oracle_hook.OracleHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.postgres_hook.PostgresHook.get_conn">(airflow.hooks.postgres_hook.PostgresHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_conn">(airflow.hooks.presto_hook.PrestoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.sqlite_hook.SqliteHook.get_conn">(airflow.hooks.sqlite_hook.SqliteHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.webhdfs_hook.WebHDFSHook.get_conn">(airflow.hooks.webhdfs_hook.WebHDFSHook method)</a> |
| </li> |
| </ul></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="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_databases">get_databases() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.druid_check_operator.DruidCheckOperator.get_db_hook">get_db_hook() (airflow.operators.druid_check_operator.DruidCheckOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.get_direct_relative_ids">get_direct_relative_ids() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_direct_relative_ids">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.get_direct_relatives">get_direct_relatives() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_direct_relatives">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.get_fernet">get_fernet() (in module airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file">get_file() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">(airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.get_file">[1]</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file_to_stream">get_file_to_stream() (airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook method)</a>, <a href="integration.html#airflow.contrib.hooks.azure_fileshare_hook.AzureFileShareHook.get_file_to_stream">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_first">get_first() (airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a> |
| |
| <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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.BaseOperator.get_flat_relative_ids">get_flat_relative_ids() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_flat_relative_ids">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.get_flat_relatives">get_flat_relatives() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.get_flat_relatives">[1]</a> |
| </li> |
| <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="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="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> |
| </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.models.XCom.get_one">get_one() (airflow.models.XCom class method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_operation">get_operation() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.get_operation">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_operation">(airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.get_operation">[1]</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_pandas_df">get_pandas_df() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.get_pandas_df">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.get_pandas_df">(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.get_pandas_df">(airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.get_pandas_df">(airflow.hooks.druid_hook.DruidDbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveServer2Hook.get_pandas_df">(airflow.hooks.hive_hooks.HiveServer2Hook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.get_pandas_df">(airflow.hooks.presto_hook.PrestoHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.hooks.hive_hooks.HiveMetastoreHook.get_partitions">get_partitions() (airflow.hooks.hive_hooks.HiveMetastoreHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagRun.get_previous_dagrun">get_previous_dagrun() (airflow.models.DagRun method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagRun.get_previous_scheduled_dagrun">get_previous_scheduled_dagrun() (airflow.models.DagRun method)</a> |
| </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> |
| </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="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.operators.gcp_container_operator.GKEClusterCreateOperator">GKEClusterCreateOperator (class in airflow.contrib.operators.gcp_container_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterCreateOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator">GKEClusterDeleteOperator (class in airflow.contrib.operators.gcp_container_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcp_container_operator.GKEClusterDeleteOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook">GKEClusterHook (class in airflow.contrib.hooks.gcp_container_hook)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook">GoogleCloudBaseHook (class in airflow.contrib.hooks.gcp_api_base_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator">GoogleCloudStorageCreateBucketOperator (class in airflow.contrib.operators.gcs_operator)</a>, <a href="integration.html#airflow.contrib.operators.gcs_operator.GoogleCloudStorageCreateBucketOperator">[1]</a> |
| </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="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_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="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.mongo_hook.MongoHook.insert_many">insert_many() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook.insert_one">insert_one() (airflow.contrib.hooks.mongo_hook.MongoHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.insert_rows">insert_rows() (airflow.contrib.hooks.bigquery_hook.BigQueryHook method)</a>, <a href="integration.html#airflow.contrib.hooks.bigquery_hook.BigQueryHook.insert_rows">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.pinot_hook.PinotDbApiHook.insert_rows">(airflow.contrib.hooks.pinot_hook.PinotDbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.dbapi_hook.DbApiHook.insert_rows">(airflow.hooks.dbapi_hook.DbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.druid_hook.DruidDbApiHook.insert_rows">(airflow.hooks.druid_hook.DruidDbApiHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.oracle_hook.OracleHook.insert_rows">(airflow.hooks.oracle_hook.OracleHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.presto_hook.PrestoHook.insert_rows">(airflow.hooks.presto_hook.PrestoHook method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.operators.check_operator.IntervalCheckOperator">IntervalCheckOperator (class in airflow.operators.check_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.models.InvalidFernetToken">InvalidFernetToken</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook.invoke_lambda">invoke_lambda() (airflow.contrib.hooks.aws_lambda_hook.AwsLambdaHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.is_eligible_to_retry">is_eligible_to_retry() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.is_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.hooks.jdbc_hook.JdbcHook">JdbcHook (class in airflow.hooks.jdbc_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.jdbc_operator.JdbcOperator">JdbcOperator (class in airflow.operators.jdbc_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.jenkins_hook.JenkinsHook">JenkinsHook (class in airflow.contrib.hooks.jenkins_hook)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator">JenkinsJobTriggerOperator (class in airflow.contrib.operators.jenkins_job_trigger_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.jira_hook.JiraHook">JiraHook (class in airflow.contrib.hooks.jira_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.jira_operator.JiraOperator">JiraOperator (class in airflow.contrib.operators.jira_operator)</a> |
| </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> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.models.KnownEvent">KnownEvent (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.KnownEventType">KnownEventType (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.KubeResourceVersion">KubeResourceVersion (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator">KubernetesPodOperator (class in airflow.contrib.operators.kubernetes_pod_operator)</a>, <a href="kubernetes.html#airflow.contrib.operators.kubernetes_pod_operator.KubernetesPodOperator">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.KubeWorkerIdentifier">KubeWorkerIdentifier (class in airflow.models)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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="integration.html#airflow.contrib.hooks.gcp_function_hook.GcfHook.list_functions">list_functions() (airflow.contrib.hooks.gcp_function_hook.GcfHook method)</a> |
| </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> |
| <li><a href="code.html#airflow.hooks.webhdfs_hook.WebHDFSHook.load_file">(airflow.hooks.webhdfs_hook.WebHDFSHook 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> |
| </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.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.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> |
| <li><a href="code.html#airflow.contrib.hooks.mongo_hook.MongoHook">MongoHook (class in airflow.contrib.hooks.mongo_hook)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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> |
| </li> |
| <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook">MySqlHook (class in airflow.hooks.mysql_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mysql_operator.MySqlOperator">MySqlOperator (class in airflow.operators.mysql_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mysql_to_gcs.MySqlToGoogleCloudStorageOperator">MySqlToGoogleCloudStorageOperator (class in airflow.contrib.operators.mysql_to_gcs)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.mysql_to_hive.MySqlToHiveTransfer">MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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.hooks.segment_hook.SegmentHook.on_error">on_error() (airflow.contrib.hooks.segment_hook.SegmentHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.awsbatch_operator.AWSBatchOperator.on_kill">on_kill() (airflow.contrib.operators.awsbatch_operator.AWSBatchOperator method)</a>, <a href="integration.html#airflow.contrib.operators.awsbatch_operator.AWSBatchOperator.on_kill">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator.on_kill">(airflow.contrib.operators.bigquery_operator.BigQueryOperator method)</a>, <a href="integration.html#airflow.contrib.operators.bigquery_operator.BigQueryOperator.on_kill">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator.on_kill">(airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator method)</a>, <a href="integration.html#airflow.contrib.operators.databricks_operator.DatabricksSubmitRunOperator.on_kill">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.ecs_operator.ECSOperator.on_kill">(airflow.contrib.operators.ecs_operator.ECSOperator method)</a>, <a href="integration.html#airflow.contrib.operators.ecs_operator.ECSOperator.on_kill">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.qubole_operator.QuboleOperator.on_kill">(airflow.contrib.operators.qubole_operator.QuboleOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator.on_kill">(airflow.contrib.operators.spark_jdbc_operator.SparkJDBCOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_sql_operator.SparkSqlOperator.on_kill">(airflow.contrib.operators.spark_sql_operator.SparkSqlOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator.on_kill">(airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sqoop_operator.SqoopOperator.on_kill">(airflow.contrib.operators.sqoop_operator.SqoopOperator method)</a> |
| </li> |
| <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> |
| <li><a href="code.html#airflow.operators.bash_operator.BashOperator.on_kill">(airflow.operators.bash_operator.BashOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.docker_operator.DockerOperator.on_kill">(airflow.operators.docker_operator.DockerOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.hive_operator.HiveOperator.on_kill">(airflow.operators.hive_operator.HiveOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.pig_operator.PigOperator.on_kill">(airflow.operators.pig_operator.PigOperator method)</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.hooks.oracle_hook.OracleHook">OracleHook (class in airflow.hooks.oracle_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.oracle_operator.OracleOperator">OracleOperator (class in airflow.operators.oracle_operator)</a> |
| </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="code.html#airflow.models.DAG.pickle_id">pickle_id (airflow.models.DAG attribute)</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_redshift_cluster_sensor.AwsRedshiftClusterSensor.poke">poke() (airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor method)</a>, <a href="integration.html#airflow.contrib.sensors.aws_redshift_cluster_sensor.AwsRedshiftClusterSensor.poke">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.sensors.bash_sensor.BashSensor.poke">(airflow.contrib.sensors.bash_sensor.BashSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor.poke">(airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.cassandra_sensor.CassandraRecordSensor.poke">(airflow.contrib.sensors.cassandra_sensor.CassandraRecordSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.datadog_sensor.DatadogSensor.poke">(airflow.contrib.sensors.datadog_sensor.DatadogSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor.poke">(airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.file_sensor.FileSensor.poke">(airflow.contrib.sensors.file_sensor.FileSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.ftp_sensor.FTPSensor.poke">(airflow.contrib.sensors.ftp_sensor.FTPSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStorageObjectUpdatedSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor.poke">(airflow.contrib.sensors.gcs_sensor.GoogleCloudStoragePrefixSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder.poke">(airflow.contrib.sensors.hdfs_sensor.HdfsSensorFolder method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex.poke">(airflow.contrib.sensors.hdfs_sensor.HdfsSensorRegex method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.jira_sensor.JiraSensor.poke">(airflow.contrib.sensors.jira_sensor.JiraSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor.poke">(airflow.contrib.sensors.pubsub_sensor.PubSubPullSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.qubole_sensor.QuboleSensor.poke">(airflow.contrib.sensors.qubole_sensor.QuboleSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.redis_key_sensor.RedisKeySensor.poke">(airflow.contrib.sensors.redis_key_sensor.RedisKeySensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.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.sensors.base_sensor_operator.BaseSensorOperator.poke">(airflow.sensors.base_sensor_operator.BaseSensorOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.external_task_sensor.ExternalTaskSensor.poke">(airflow.sensors.external_task_sensor.ExternalTaskSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.hdfs_sensor.HdfsSensor.poke">(airflow.sensors.hdfs_sensor.HdfsSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.hive_partition_sensor.HivePartitionSensor.poke">(airflow.sensors.hive_partition_sensor.HivePartitionSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.http_sensor.HttpSensor.poke">(airflow.sensors.http_sensor.HttpSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor.poke">(airflow.sensors.metastore_partition_sensor.MetastorePartitionSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor.poke">(airflow.sensors.named_hive_partition_sensor.NamedHivePartitionSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.s3_key_sensor.S3KeySensor.poke">(airflow.sensors.s3_key_sensor.S3KeySensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.s3_prefix_sensor.S3PrefixSensor.poke">(airflow.sensors.s3_prefix_sensor.S3PrefixSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.sql_sensor.SqlSensor.poke">(airflow.sensors.sql_sensor.SqlSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.time_delta_sensor.TimeDeltaSensor.poke">(airflow.sensors.time_delta_sensor.TimeDeltaSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.time_sensor.TimeSensor.poke">(airflow.sensors.time_sensor.TimeSensor method)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.web_hdfs_sensor.WebHdfsSensor.poke">(airflow.sensors.web_hdfs_sensor.WebHdfsSensor method)</a> |
| </li> |
| </ul></li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator.poll_job_in_queue">poll_job_in_queue() (airflow.contrib.operators.jenkins_job_trigger_operator.JenkinsJobTriggerOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.poll_operation_until_done">poll_operation_until_done() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.poll_operation_until_done">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.Pool">Pool (class in airflow.models)</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.pool_full">pool_full() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.sqoop_hook.SqoopHook.Popen">Popen() (airflow.contrib.hooks.sqoop_hook.SqoopHook method)</a> |
| </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> |
| |
| <ul> |
| <li><a href="code.html#airflow.operators.hive_operator.HiveOperator.prepare_template">(airflow.operators.hive_operator.HiveOperator method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.pig_operator.PigOperator.prepare_template">(airflow.operators.pig_operator.PigOperator method)</a> |
| </li> |
| </ul></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.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> |
| </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> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.contrib.sensors.qubole_sensor.QuboleSensor">QuboleSensor (class in airflow.contrib.sensors.qubole_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.qubole_check_operator.QuboleValueCheckOperator">QuboleValueCheckOperator (class in airflow.contrib.operators.qubole_check_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook.query_metric">query_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.Pool.queued_slots">queued_slots() (airflow.models.Pool method)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <h2 id="R">R</h2> |
| <table style="width: 100%" class="indextable genindextable"><tr> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <li><a href="code.html#airflow.macros.random">random() (in module airflow.macros)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook.read_file">read_file() (airflow.contrib.hooks.wasb_hook.WasbHook method)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook.read_file">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.read_key">read_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.read_key">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.TaskInstance.ready_for_retry">ready_for_retry() (airflow.models.TaskInstance method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook.record_exists">record_exists() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.redis_hook.RedisHook">RedisHook (class in airflow.contrib.hooks.redis_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.redis_key_sensor.RedisKeySensor">RedisKeySensor (class in airflow.contrib.sensors.redis_key_sensor)</a> |
| </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="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> |
| </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.datastore_hook.DatastoreHook.run_query">run_query() (airflow.contrib.hooks.datastore_hook.DatastoreHook method)</a>, <a href="integration.html#airflow.contrib.hooks.datastore_hook.DatastoreHook.run_query">[1]</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.contrib.hooks.spark_sql_hook.SparkSqlHook.run_query">(airflow.contrib.hooks.spark_sql_hook.SparkSqlHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.hooks.http_hook.HttpHook.run_with_advanced_retry">run_with_advanced_retry() (airflow.hooks.http_hook.HttpHook method)</a> |
| </li> |
| </ul></td> |
| </tr></table> |
| |
| <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.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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_endpoint_operator.SageMakerEndpointOperator">SageMakerEndpointOperator (class in airflow.contrib.operators.sagemaker_endpoint_operator)</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> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_model_operator.SageMakerModelOperator">SageMakerModelOperator (class in airflow.contrib.operators.sagemaker_model_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.sagemaker_training_operator.SageMakerTrainingOperator">SageMakerTrainingOperator (class in airflow.contrib.operators.sagemaker_training_operator)</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> |
| </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> |
| </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.hooks.samba_hook.SambaHook">SambaHook (class in airflow.hooks.samba_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.schedule_interval">schedule_interval (airflow.models.BaseOperator attribute)</a>, <a href="code.html#airflow.models.BaseOperator.schedule_interval">[1]</a> |
| </li> |
| <li><a href="kubernetes.html#airflow.contrib.kubernetes.secret.Secret">Secret (class in airflow.contrib.kubernetes.secret)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.segment_hook.SegmentHook">SegmentHook (class in airflow.contrib.hooks.segment_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.segment_track_event_operator.SegmentTrackEventOperator">SegmentTrackEventOperator (class in airflow.contrib.operators.segment_track_event_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.S3_hook.S3Hook.select_key">select_key() (airflow.hooks.S3_hook.S3Hook method)</a>, <a href="integration.html#airflow.hooks.S3_hook.S3Hook.select_key">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.datadog_hook.DatadogHook.send_metric">send_metric() (airflow.contrib.hooks.datadog_hook.DatadogHook method)</a> |
| </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.jdbc_hook.JdbcHook.set_autocommit">(airflow.hooks.jdbc_hook.JdbcHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.mssql_hook.MsSqlHook.set_autocommit">(airflow.hooks.mssql_hook.MsSqlHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.hooks.mysql_hook.MySqlHook.set_autocommit">(airflow.hooks.mysql_hook.MySqlHook method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.set_default_version">set_default_version() (airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_mlengine_hook.MLEngineHook.set_default_version">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.set_dependency">set_dependency() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagStat.set_dirty">set_dirty() (airflow.models.DagStat static method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.set_downstream">set_downstream() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.set_downstream">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.BaseOperator.set_upstream">set_upstream() (airflow.models.BaseOperator method)</a>, <a href="code.html#airflow.models.BaseOperator.set_upstream">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.models.Variable.setdefault">setdefault() (airflow.models.Variable class method)</a> |
| </li> |
| </ul></td> |
| <td style="width: 33%; vertical-align: top;"><ul> |
| <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> |
| <li><a href="code.html#airflow.contrib.hooks.cassandra_hook.CassandraHook.shutdown_cluster">shutdown_cluster() (airflow.contrib.hooks.cassandra_hook.CassandraHook method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.http_operator.SimpleHttpOperator">SimpleHttpOperator (class in airflow.operators.http_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DagBag.size">size() (airflow.models.DagBag method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.SkipMixin.skip">skip() (airflow.models.SkipMixin method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.SkipMixin">SkipMixin (class in airflow.models)</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.executors.celery_executor.CeleryExecutor.start">start() (airflow.executors.celery_executor.CeleryExecutor method)</a> |
| |
| <ul> |
| <li><a href="code.html#airflow.executors.local_executor.LocalExecutor.start">(airflow.executors.local_executor.LocalExecutor method)</a> |
| </li> |
| </ul></li> |
| <li><a href="code.html#airflow.contrib.hooks.ftp_hook.FTPHook.store_file">store_file() (airflow.contrib.hooks.ftp_hook.FTPHook method)</a> |
| |
| <ul> |
| <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.executors.celery_executor.CeleryExecutor.sync">sync() (airflow.executors.celery_executor.CeleryExecutor method)</a> |
| |
| <ul> |
| <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.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> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.task_ids">task_ids (airflow.models.DAG attribute)</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.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.models.DAG.topological_sort">topological_sort() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.mongo_to_s3.MongoToS3Operator.transform">transform() (airflow.contrib.operators.mongo_to_s3.MongoToS3Operator method)</a> |
| </li> |
| <li><a href="code.html#airflow.models.DAG.tree_view">tree_view() (airflow.models.DAG method)</a> |
| </li> |
| <li><a href="code.html#airflow.operators.dagrun_operator.TriggerDagRunOperator">TriggerDagRunOperator (class in airflow.operators.dagrun_operator)</a> |
| </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> |
| |
| <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> |
| </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.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.hooks.gcp_container_hook.GKEClusterHook.wait_for_operation">wait_for_operation() (airflow.contrib.hooks.gcp_container_hook.GKEClusterHook method)</a>, <a href="integration.html#airflow.contrib.hooks.gcp_container_hook.GKEClusterHook.wait_for_operation">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor">WasbBlobSensor (class in airflow.contrib.sensors.wasb_sensor)</a>, <a href="integration.html#airflow.contrib.sensors.wasb_sensor.WasbBlobSensor">[1]</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.wasb_hook.WasbHook">WasbHook (class in airflow.contrib.hooks.wasb_hook)</a>, <a href="integration.html#airflow.contrib.hooks.wasb_hook.WasbHook">[1]</a> |
| </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.hooks.webhdfs_hook.WebHDFSHook">WebHDFSHook (class in airflow.hooks.webhdfs_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.sensors.web_hdfs_sensor.WebHdfsSensor">WebHdfsSensor (class in airflow.sensors.web_hdfs_sensor)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.winrm_hook.WinRMHook">WinRMHook (class in airflow.contrib.hooks.winrm_hook)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.operators.winrm_operator.WinRMOperator">WinRMOperator (class in airflow.contrib.operators.winrm_operator)</a> |
| </li> |
| <li><a href="code.html#airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook.write_batch_data">write_batch_data() (airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook method)</a> |
| </li> |
| </ul></td> |
| </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/js/theme.js"></script> |
| |
| <script type="text/javascript"> |
| jQuery(function () { |
| SphinxRtdTheme.Navigation.enable(true); |
| }); |
| </script> |
| |
| </body> |
| </html> |
