• Home
• Index

Index

_

__version__ (in module airflow.providers.yandex)

A

airflow.providers.yandex module airflow.providers.yandex.hooks 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.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.yandexcloud_dataproc.InitializationAction attribute) AVAILABILITY_ZONE_ID (in module tests.system.providers.yandex.example_yandexcloud_dataproc) (in module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight)

C

close() (airflow.providers.yandex.hooks.yq.YQHook method) cluster_id (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreateClusterOperator property) (in module tests.system.providers.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.providers.yandex.example_yandexcloud_dataproc) (in module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight) create_cluster() (in module tests.system.providers.yandex.example_yandexcloud) create_cluster_request() (in module tests.system.providers.yandex.example_yandexcloud) create_query() (airflow.providers.yandex.hooks.yq.YQHook method)

D

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

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

E

ENV_ID (in module tests.system.providers.yandex.example_yandexcloud) (in module tests.system.providers.yandex.example_yandexcloud_dataproc) (in module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight) execute() (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocBaseOperator method) (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreateClusterOperator method) (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreateHiveJobOperator method) (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreateMapReduceJobOperator method) (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreatePysparkJobOperator method) (airflow.providers.yandex.operators.yandexcloud_dataproc.DataprocCreateSparkJobOperator method) (airflow.providers.yandex.operators.yandexcloud_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.yandexcloud_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.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.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.providers.yandex tests.system.providers.yandex.example_yandexcloud tests.system.providers.yandex.example_yandexcloud_dataproc tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight

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.providers.yandex.example_yandexcloud)

S

S3_BUCKET_NAME (in module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight)

S3_BUCKET_NAME_FOR_JOB_LOGS (in module tests.system.providers.yandex.example_yandexcloud_dataproc) 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.yandexcloud_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.providers.yandex.example_yandexcloud) (in module tests.system.providers.yandex.example_yandexcloud_dataproc) (in module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight) tests.system.providers.yandex module

tests.system.providers.yandex.example_yandexcloud module tests.system.providers.yandex.example_yandexcloud_dataproc module tests.system.providers.yandex.example_yandexcloud_dataproc_lightweight module timeout (airflow.providers.yandex.operators.yandexcloud_dataproc.InitializationAction attribute)

U

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

uri (airflow.providers.yandex.operators.yandexcloud_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.providers.yandex.example_yandexcloud) YC_S3_BUCKET_NAME (in module tests.system.providers.yandex.example_yandexcloud) YC_SERVICE_ACCOUNT_ID (in module tests.system.providers.yandex.example_yandexcloud)

YC_SUBNET_ID (in module tests.system.providers.yandex.example_yandexcloud) YC_ZONE_NAME (in module tests.system.providers.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?