• Home
• Index

Index

_

__enter__() (airflow.providers.teradata.hooks.ttu.TtuHook method)

__exit__() (airflow.providers.teradata.hooks.ttu.TtuHook method) __version__ (in module airflow.providers.teradata)

A

airflow.providers.teradata module airflow.providers.teradata.get_provider_info module airflow.providers.teradata.hooks module airflow.providers.teradata.hooks.bteq module airflow.providers.teradata.hooks.teradata module airflow.providers.teradata.hooks.ttu module airflow.providers.teradata.operators module airflow.providers.teradata.operators.bteq module airflow.providers.teradata.operators.teradata module airflow.providers.teradata.operators.teradata_compute_cluster module airflow.providers.teradata.transfers module

airflow.providers.teradata.transfers.azure_blob_to_teradata module airflow.providers.teradata.transfers.s3_to_teradata module airflow.providers.teradata.transfers.teradata_to_teradata module airflow.providers.teradata.triggers module airflow.providers.teradata.triggers.teradata_compute_cluster module airflow.providers.teradata.utils module airflow.providers.teradata.utils.bteq_util module airflow.providers.teradata.utils.constants module airflow.providers.teradata.utils.encryption_utils module AIRFLOW_CONN_{CONN_ID}, [1] aws_conn_id (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) azure_conn_id (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) AzureBlobStorageToTeradataOperator (class in airflow.providers.teradata.transfers.azure_blob_to_teradata)

B

blob_source_key (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) bteq_quit_rc (airflow.providers.teradata.operators.bteq.BteqOperator attribute) bteq_script_encoding (airflow.providers.teradata.operators.bteq.BteqOperator attribute)

bteq_session_encoding (airflow.providers.teradata.operators.bteq.BteqOperator attribute) BteqHook (class in airflow.providers.teradata.hooks.bteq) BteqOperator (class in airflow.providers.teradata.operators.bteq)

C

callproc() (airflow.providers.teradata.hooks.teradata.TeradataHook method) CC_CREATE_OPR (airflow.providers.teradata.utils.constants.Constants attribute) CC_CREATE_SUSPEND_OPR (airflow.providers.teradata.utils.constants.Constants attribute) CC_DROP_OPR (airflow.providers.teradata.utils.constants.Constants attribute) CC_GRP_LAKE_SUPPORT_ONLY_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_GRP_PRP_EXISTS_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_GRP_PRP_NON_EXISTS_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_GRP_PRP_UN_AUTHORIZED_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_INITIALIZE_DB_STATUS (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_EMPTY_COPY_PROFILE_ERROR_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_EMPTY_PROFILE_ERROR_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_FAILURE_STATUS_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_INITIALIZING_STATUS_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_SUCCESS_STATUS_MSG (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_TIME_OUT (airflow.providers.teradata.utils.constants.Constants attribute) CC_OPR_TIMEOUT_ERROR (airflow.providers.teradata.utils.constants.Constants attribute) CC_POLL_INTERVAL (airflow.providers.teradata.utils.constants.Constants attribute) CC_RESUME_DB_STATUS (airflow.providers.teradata.utils.constants.Constants attribute) CC_RESUME_OPR (airflow.providers.teradata.utils.constants.Constants attribute) CC_SUSPEND_DB_STATUS (airflow.providers.teradata.utils.constants.Constants attribute) CC_SUSPEND_OPR (airflow.providers.teradata.utils.constants.Constants attribute) close_conn() (airflow.providers.teradata.hooks.ttu.TtuHook method) compute_attribute (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator attribute)

compute_cluster_provision_operation (in module tests.system.teradata.example_teradata_compute_cluster) compute_group_name (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger attribute) compute_map (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator attribute) compute_profile_name (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger attribute) conn (airflow.providers.teradata.hooks.ttu.TtuHook attribute) conn_id (airflow.providers.teradata.operators.teradata.TeradataOperator attribute) CONN_ID (in module tests.system.teradata.example_azure_blob_to_teradata_transfer) (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) (in module tests.system.teradata.example_s3_to_teradata_transfer) (in module tests.system.teradata.example_ssl_teradata) (in module tests.system.teradata.example_teradata) (in module tests.system.teradata.example_teradata_call_sp) (in module tests.system.teradata.example_teradata_to_teradata_transfer) conn_name_attr (airflow.providers.teradata.hooks.teradata.TeradataHook attribute) conn_type (airflow.providers.teradata.hooks.teradata.TeradataHook attribute) Constants (class in airflow.providers.teradata.utils.constants) contains_template() (in module airflow.providers.teradata.operators.bteq) create_country_table (in module tests.system.teradata.example_ssl_teradata) create_sp_in_inout (in module tests.system.teradata.example_teradata_call_sp) create_src_table (in module tests.system.teradata.example_teradata_to_teradata_transfer) create_table (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) (in module tests.system.teradata.example_teradata)

D

DAG_ID (in module tests.system.teradata.example_azure_blob_to_teradata_transfer) (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) (in module tests.system.teradata.example_s3_to_teradata_transfer) (in module tests.system.teradata.example_ssl_teradata) (in module tests.system.teradata.example_teradata) (in module tests.system.teradata.example_teradata_call_sp) (in module tests.system.teradata.example_teradata_compute_cluster) (in module tests.system.teradata.example_teradata_to_teradata_transfer)

decrypt_remote_file_to_string() (in module airflow.providers.teradata.utils.encryption_utils) default_conn_name (airflow.providers.teradata.hooks.teradata.TeradataHook attribute) delete_compute_group (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator attribute) dest_hook (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator property) dest_teradata_conn_id (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) destination_table (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute)

E

ENV_ID (in module tests.system.teradata.example_azure_blob_to_teradata_transfer) (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) (in module tests.system.teradata.example_s3_to_teradata_transfer) (in module tests.system.teradata.example_ssl_teradata) (in module tests.system.teradata.example_teradata) (in module tests.system.teradata.example_teradata_compute_cluster) (in module tests.system.teradata.example_teradata_to_teradata_transfer) environment variable AIRFLOW_CONN_{CONN_ID}, [1] execute() (airflow.providers.teradata.operators.bteq.BteqOperator method) (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator method) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator method) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator method) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator method) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator method) (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator method) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator method) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator method)

execute_bteq_script() (airflow.providers.teradata.hooks.bteq.BteqHook method) execute_bteq_script_at_local() (airflow.providers.teradata.hooks.bteq.BteqHook method) execute_bteq_script_at_remote() (airflow.providers.teradata.hooks.bteq.BteqHook method)

F

file_path (airflow.providers.teradata.operators.bteq.BteqOperator attribute)

G

generate_encrypted_file_with_openssl() (in module airflow.providers.teradata.utils.encryption_utils) generate_random_password() (in module airflow.providers.teradata.utils.encryption_utils) get_airflow_home_dir() (airflow.providers.teradata.hooks.bteq.BteqHook method) get_conn() (airflow.providers.teradata.hooks.teradata.TeradataHook method) (airflow.providers.teradata.hooks.ttu.TtuHook method)

get_provider_info() (in module airflow.providers.teradata.get_provider_info) get_sqlalchemy_engine() (airflow.providers.teradata.hooks.teradata.TeradataHook method) get_status() (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger method) get_ui_field_behaviour() (airflow.providers.teradata.hooks.teradata.TeradataHook static method)

H

hook_name (airflow.providers.teradata.hooks.teradata.TeradataHook attribute)

host (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq)

I

is_valid_encoding() (in module airflow.providers.teradata.utils.bteq_util)

is_valid_file() (in module airflow.providers.teradata.utils.bteq_util) is_valid_remote_bteq_script_file() (in module airflow.providers.teradata.utils.bteq_util)

M

module airflow.providers.teradata airflow.providers.teradata.get_provider_info airflow.providers.teradata.hooks airflow.providers.teradata.hooks.bteq airflow.providers.teradata.hooks.teradata airflow.providers.teradata.hooks.ttu airflow.providers.teradata.operators airflow.providers.teradata.operators.bteq airflow.providers.teradata.operators.teradata airflow.providers.teradata.operators.teradata_compute_cluster airflow.providers.teradata.transfers airflow.providers.teradata.transfers.azure_blob_to_teradata airflow.providers.teradata.transfers.s3_to_teradata airflow.providers.teradata.transfers.teradata_to_teradata airflow.providers.teradata.triggers airflow.providers.teradata.triggers.teradata_compute_cluster airflow.providers.teradata.utils airflow.providers.teradata.utils.bteq_util airflow.providers.teradata.utils.constants airflow.providers.teradata.utils.encryption_utils tests.system.teradata tests.system.teradata.example_azure_blob_to_teradata_transfer tests.system.teradata.example_bteq tests.system.teradata.example_remote_bteq tests.system.teradata.example_s3_to_teradata_transfer tests.system.teradata.example_ssl_teradata tests.system.teradata.example_teradata tests.system.teradata.example_teradata_call_sp tests.system.teradata.example_teradata_compute_cluster tests.system.teradata.example_teradata_to_teradata_transfer

O

on_kill() (airflow.providers.teradata.hooks.bteq.BteqHook method) (airflow.providers.teradata.operators.bteq.BteqOperator method)

operation_type (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger attribute)

P

PARAM_TYPES (in module airflow.providers.teradata.hooks.teradata) parameters (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator attribute) params (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) password (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) placeholder (airflow.providers.teradata.hooks.teradata.TeradataHook attribute) poll_interval (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger attribute)

preferred_temp_directory() (airflow.providers.teradata.hooks.bteq.BteqHook method) prepare_bteq_command_for_local_execution() (in module airflow.providers.teradata.utils.bteq_util) prepare_bteq_command_for_remote_execution() (in module airflow.providers.teradata.utils.bteq_util) prepare_bteq_script_for_local_execution() (in module airflow.providers.teradata.utils.bteq_util) prepare_bteq_script_for_remote_execution() (in module airflow.providers.teradata.utils.bteq_util) procedure (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator attribute) public_bucket (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute)

Q

query_strategy (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator attribute)

R

read_file() (in module airflow.providers.teradata.utils.bteq_util) remote_working_dir (airflow.providers.teradata.operators.bteq.BteqOperator attribute)

rows_chunk (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) run() (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger method)

S

s3_source_key (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) S3ToTeradataOperator (class in airflow.providers.teradata.transfers.s3_to_teradata) serialize() (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger method) set_query_band() (airflow.providers.teradata.hooks.teradata.TeradataHook method) shell_quote_single() (in module airflow.providers.teradata.utils.encryption_utils) source_teradata_conn_id (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) sql (airflow.providers.teradata.operators.bteq.BteqOperator attribute) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute)

sql_params (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) src_hook (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator property) ssh_conn_id (airflow.providers.teradata.hooks.bteq.BteqHook attribute) (airflow.providers.teradata.operators.bteq.BteqOperator attribute) SSH_CONN_ID (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) ssh_hook (airflow.providers.teradata.hooks.bteq.BteqHook attribute) supports_autocommit (airflow.providers.teradata.hooks.teradata.TeradataHook attribute) supports_executemany (airflow.providers.teradata.hooks.teradata.TeradataHook attribute)

T

temp_file_read_encoding (airflow.providers.teradata.operators.bteq.BteqOperator attribute) template_ext (airflow.providers.teradata.operators.teradata.TeradataOperator attribute) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) template_fields (airflow.providers.teradata.operators.bteq.BteqOperator attribute) (airflow.providers.teradata.operators.teradata.TeradataOperator attribute) (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator attribute) (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) template_fields_renderers (airflow.providers.teradata.operators.teradata.TeradataOperator attribute) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute) teradata_authorization_name (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) teradata_conn_id (airflow.providers.teradata.hooks.ttu.TtuHook attribute) (airflow.providers.teradata.operators.bteq.BteqOperator attribute) (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator attribute) (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) (airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger attribute) teradata_table (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) TeradataComputeClusterDecommissionOperator (class in airflow.providers.teradata.operators.teradata_compute_cluster) TeradataComputeClusterProvisionOperator (class in airflow.providers.teradata.operators.teradata_compute_cluster) TeradataComputeClusterResumeOperator (class in airflow.providers.teradata.operators.teradata_compute_cluster) TeradataComputeClusterSuspendOperator (class in airflow.providers.teradata.operators.teradata_compute_cluster) TeradataComputeClusterSyncTrigger (class in airflow.providers.teradata.triggers.teradata_compute_cluster) TeradataHook (class in airflow.providers.teradata.hooks.teradata) TeradataOperator (class in airflow.providers.teradata.operators.teradata) TeradataStoredProcedureOperator (class in airflow.providers.teradata.operators.teradata) TeradataToTeradataOperator (class in airflow.providers.teradata.transfers.teradata_to_teradata)

test_run (in module tests.system.teradata.example_azure_blob_to_teradata_transfer) (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq) (in module tests.system.teradata.example_s3_to_teradata_transfer) (in module tests.system.teradata.example_ssl_teradata) (in module tests.system.teradata.example_teradata) (in module tests.system.teradata.example_teradata_call_sp) (in module tests.system.teradata.example_teradata_compute_cluster) (in module tests.system.teradata.example_teradata_to_teradata_transfer) tests.system.teradata module tests.system.teradata.example_azure_blob_to_teradata_transfer module tests.system.teradata.example_bteq module tests.system.teradata.example_remote_bteq module tests.system.teradata.example_s3_to_teradata_transfer module tests.system.teradata.example_ssl_teradata module tests.system.teradata.example_teradata module tests.system.teradata.example_teradata_call_sp module tests.system.teradata.example_teradata_compute_cluster module tests.system.teradata.example_teradata_to_teradata_transfer module timeout (airflow.providers.teradata.operators.bteq.BteqOperator attribute) timeout_rc (airflow.providers.teradata.operators.bteq.BteqOperator attribute) transfer_data_csv (in module tests.system.teradata.example_azure_blob_to_teradata_transfer) (in module tests.system.teradata.example_s3_to_teradata_transfer) transfer_file_sftp() (in module airflow.providers.teradata.utils.bteq_util) TtuHook (class in airflow.providers.teradata.hooks.ttu)

U

ui_color (airflow.providers.teradata.operators.bteq.BteqOperator attribute) (airflow.providers.teradata.operators.teradata.TeradataOperator attribute) (airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator attribute) (airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator attribute) (airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator attribute) (airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator attribute) (airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator attribute)

username (in module tests.system.teradata.example_bteq) (in module tests.system.teradata.example_remote_bteq)

V

verify_bteq_installed() (in module airflow.providers.teradata.utils.bteq_util)

verify_bteq_installed_remote() (in module airflow.providers.teradata.utils.bteq_util)

PreviousNext

Was this entry helpful?