• Home
• Index

Index

_

__version__ (in module airflow.providers.yandex)

A

airflow.providers.yandex module airflow.providers.yandex.hooks module airflow.providers.yandex.hooks.dataproc module airflow.providers.yandex.hooks.yandex module airflow.providers.yandex.hooks.yandexcloud_dataproc module airflow.providers.yandex.hooks.yq module airflow.providers.yandex.links module airflow.providers.yandex.links.yq module airflow.providers.yandex.operators module airflow.providers.yandex.operators.dataproc module

airflow.providers.yandex.operators.yandexcloud_dataproc module airflow.providers.yandex.operators.yq module airflow.providers.yandex.secrets module airflow.providers.yandex.secrets.lockbox module airflow.providers.yandex.utils module airflow.providers.yandex.utils.credentials module airflow.providers.yandex.utils.defaults module airflow.providers.yandex.utils.fields module airflow.providers.yandex.utils.user_agent module args (airflow.providers.yandex.operators.dataproc.InitializationAction attribute) AVAILABILITY_ZONE_ID (in module tests.system.yandex.example_yandexcloud_dataproc) (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight)

C

client (airflow.providers.yandex.hooks.dataproc.DataprocHook property) close() (airflow.providers.yandex.hooks.yq.YQHook method) cluster_id (airflow.providers.yandex.operators.dataproc.DataprocCreateClusterOperator property) (in module tests.system.yandex.example_yandexcloud) compose_query_web_link() (airflow.providers.yandex.hooks.yq.YQHook method) conn_name_attr (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook attribute) (in module airflow.providers.yandex.utils.defaults)

conn_type (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook attribute) (in module airflow.providers.yandex.utils.defaults) create_cluster (in module tests.system.yandex.example_yandexcloud_dataproc) (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight) create_cluster() (in module tests.system.yandex.example_yandexcloud) create_cluster_request() (in module tests.system.yandex.example_yandexcloud) create_query() (airflow.providers.yandex.hooks.yq.YQHook method) CredentialsType (class in airflow.providers.yandex.utils.credentials)

D

DAG_ID (in module tests.system.yandex.example_yandexcloud) (in module tests.system.yandex.example_yandexcloud_dataproc) (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight) (in module tests.system.yandex.example_yandexcloud_yq) DataprocBaseOperator (class in airflow.providers.yandex.operators.dataproc) DataprocCreateClusterOperator (class in airflow.providers.yandex.operators.dataproc) DataprocCreateHiveJobOperator (class in airflow.providers.yandex.operators.dataproc)

DataprocCreateMapReduceJobOperator (class in airflow.providers.yandex.operators.dataproc) DataprocCreatePysparkJobOperator (class in airflow.providers.yandex.operators.dataproc) DataprocCreateSparkJobOperator (class in airflow.providers.yandex.operators.dataproc) DataprocDeleteClusterOperator (class in airflow.providers.yandex.operators.dataproc) DataprocHook (class in airflow.providers.yandex.hooks.dataproc) default_conn_name (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook attribute) (in module airflow.providers.yandex.utils.defaults) delete_cluster() (in module tests.system.yandex.example_yandexcloud)

E

ENV_ID (in module tests.system.yandex.example_yandexcloud) (in module tests.system.yandex.example_yandexcloud_dataproc) (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight) (in module tests.system.yandex.example_yandexcloud_yq) execute() (airflow.providers.yandex.operators.dataproc.DataprocBaseOperator method) (airflow.providers.yandex.operators.dataproc.DataprocCreateClusterOperator method) (airflow.providers.yandex.operators.dataproc.DataprocCreateHiveJobOperator method) (airflow.providers.yandex.operators.dataproc.DataprocCreateMapReduceJobOperator method) (airflow.providers.yandex.operators.dataproc.DataprocCreatePysparkJobOperator method) (airflow.providers.yandex.operators.dataproc.DataprocCreateSparkJobOperator method) (airflow.providers.yandex.operators.dataproc.DataprocDeleteClusterOperator method) (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator method)

G

get_config() (airflow.providers.yandex.secrets.lockbox.LockboxSecretBackend method) get_conn_value() (airflow.providers.yandex.secrets.lockbox.LockboxSecretBackend method) get_connection_form_widgets() (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook class method) get_credentials() (in module airflow.providers.yandex.utils.credentials) get_field_from_extras() (in module airflow.providers.yandex.utils.fields) get_link() (airflow.providers.yandex.links.yq.YQLink method)

get_query() (airflow.providers.yandex.hooks.yq.YQHook method) get_query_status() (airflow.providers.yandex.hooks.yq.YQHook method) get_service_account_id() (in module airflow.providers.yandex.utils.credentials) get_service_account_key() (in module airflow.providers.yandex.utils.credentials) get_ui_field_behaviour() (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook class method) get_variable() (airflow.providers.yandex.secrets.lockbox.LockboxSecretBackend method)

H

hook() (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator method)

hook_name (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook attribute) (in module airflow.providers.yandex.utils.defaults)

I

InitializationAction (class in airflow.providers.yandex.operators.dataproc)

L

LockboxSecretBackend (class in airflow.providers.yandex.secrets.lockbox)

log (in module airflow.providers.yandex.utils.credentials)

M

module airflow.providers.yandex airflow.providers.yandex.hooks airflow.providers.yandex.hooks.dataproc airflow.providers.yandex.hooks.yandex airflow.providers.yandex.hooks.yandexcloud_dataproc airflow.providers.yandex.hooks.yq airflow.providers.yandex.links airflow.providers.yandex.links.yq airflow.providers.yandex.operators airflow.providers.yandex.operators.dataproc airflow.providers.yandex.operators.yandexcloud_dataproc airflow.providers.yandex.operators.yq airflow.providers.yandex.secrets airflow.providers.yandex.secrets.lockbox airflow.providers.yandex.utils airflow.providers.yandex.utils.credentials airflow.providers.yandex.utils.defaults airflow.providers.yandex.utils.fields airflow.providers.yandex.utils.user_agent tests.system.yandex tests.system.yandex.example_yandexcloud tests.system.yandex.example_yandexcloud_dataproc tests.system.yandex.example_yandexcloud_dataproc_lightweight tests.system.yandex.example_yandexcloud_yq

N

name (airflow.providers.yandex.links.yq.YQLink attribute)

O

on_kill() (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator method)

operator_extra_links (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator attribute)

P

persist() (airflow.providers.yandex.links.yq.YQLink static method)

provider_user_agent() (airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook class method) (in module airflow.providers.yandex.utils.user_agent)

R

run_spark_job() (in module tests.system.yandex.example_yandexcloud)

run_this_last (in module tests.system.yandex.example_yandexcloud_yq)

S

S3_BUCKET_NAME (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight) S3_BUCKET_NAME_FOR_JOB_LOGS (in module tests.system.yandex.example_yandexcloud_dataproc)

service_account_key (airflow.providers.yandex.utils.credentials.CredentialsType attribute) stop_query() (airflow.providers.yandex.hooks.yq.YQHook method)

T

template_ext (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator attribute) template_fields (airflow.providers.yandex.operators.dataproc.DataprocBaseOperator attribute) (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator attribute) template_fields_renderers (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator attribute) test_run (in module tests.system.yandex.example_yandexcloud) (in module tests.system.yandex.example_yandexcloud_dataproc) (in module tests.system.yandex.example_yandexcloud_dataproc_lightweight) (in module tests.system.yandex.example_yandexcloud_yq) tests.system.yandex module

tests.system.yandex.example_yandexcloud module tests.system.yandex.example_yandexcloud_dataproc module tests.system.yandex.example_yandexcloud_dataproc_lightweight module tests.system.yandex.example_yandexcloud_yq module timeout (airflow.providers.yandex.operators.dataproc.InitializationAction attribute) token (airflow.providers.yandex.utils.credentials.CredentialsType attribute)

U

ui_color (airflow.providers.yandex.operators.yq.YQExecuteQueryOperator attribute)

uri (airflow.providers.yandex.operators.dataproc.InitializationAction attribute)

W

wait_results() (airflow.providers.yandex.hooks.yq.YQHook method)

X

XCOM_WEBLINK_KEY (in module airflow.providers.yandex.links.yq)

Y

YandexCloudBaseHook (class in airflow.providers.yandex.hooks.yandex) YC_FOLDER_ID (in module tests.system.yandex.example_yandexcloud) YC_S3_BUCKET_NAME (in module tests.system.yandex.example_yandexcloud) YC_SERVICE_ACCOUNT_ID (in module tests.system.yandex.example_yandexcloud)

YC_SUBNET_ID (in module tests.system.yandex.example_yandexcloud) YC_ZONE_NAME (in module tests.system.yandex.example_yandexcloud) YQExecuteQueryOperator (class in airflow.providers.yandex.operators.yq) YQHook (class in airflow.providers.yandex.hooks.yq) YQLink (class in airflow.providers.yandex.links.yq)

PreviousNext

Was this entry helpful?