• Home
• Index

Index

_

__version__ (in module airflow.providers.trino)

A

airflow.providers.trino module airflow.providers.trino.assets module airflow.providers.trino.assets.trino module airflow.providers.trino.get_provider_info module airflow.providers.trino.hooks module

airflow.providers.trino.hooks.trino module airflow.providers.trino.transfers module airflow.providers.trino.transfers.gcs_to_trino module airflow.providers.trino.version_compat module AIRFLOW_V_2_10_PLUS (in module airflow.providers.trino.version_compat) AIRFLOW_V_3_0_PLUS (in module airflow.providers.trino.version_compat)

B

BUCKET (in module tests.system.trino.example_gcs_to_trino)

C

conn_name_attr (airflow.providers.trino.hooks.trino.TrinoHook attribute)

conn_type (airflow.providers.trino.hooks.trino.TrinoHook attribute)

D

DAG_ID (in module tests.system.trino.example_gcs_to_trino)

default_conn_name (airflow.providers.trino.hooks.trino.TrinoHook attribute)

E

ENV_ID (in module tests.system.trino.example_gcs_to_trino)

execute() (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator method)

G

gcp_conn_id (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) gcs_csv_to_trino_table (in module tests.system.trino.example_gcs_to_trino) GCSToTrinoOperator (class in airflow.providers.trino.transfers.gcs_to_trino) generate_trino_client_info() (in module airflow.providers.trino.hooks.trino) get_base_airflow_version_tuple() (in module airflow.providers.trino.version_compat) get_conn() (airflow.providers.trino.hooks.trino.TrinoHook method) get_first() (airflow.providers.trino.hooks.trino.TrinoHook method)

get_isolation_level() (airflow.providers.trino.hooks.trino.TrinoHook method) get_openlineage_database_dialect() (airflow.providers.trino.hooks.trino.TrinoHook method) get_openlineage_database_info() (airflow.providers.trino.hooks.trino.TrinoHook method) get_openlineage_default_schema() (airflow.providers.trino.hooks.trino.TrinoHook method) get_pandas_df() (airflow.providers.trino.hooks.trino.TrinoHook method) get_provider_info() (in module airflow.providers.trino.get_provider_info) get_records() (airflow.providers.trino.hooks.trino.TrinoHook method)

H

hook_name (airflow.providers.trino.hooks.trino.TrinoHook attribute)

I

impersonation_chain (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute)

insert_rows() (airflow.providers.trino.hooks.trino.TrinoHook method)

M

module airflow.providers.trino airflow.providers.trino.assets airflow.providers.trino.assets.trino airflow.providers.trino.get_provider_info airflow.providers.trino.hooks airflow.providers.trino.hooks.trino airflow.providers.trino.transfers airflow.providers.trino.transfers.gcs_to_trino airflow.providers.trino.version_compat tests.system.trino tests.system.trino.example_gcs_to_trino tests.system.trino.example_trino

P

PATH_TO_FILE (in module tests.system.trino.example_gcs_to_trino)

Q

query_id (airflow.providers.trino.hooks.trino.TrinoHook attribute)

S

sanitize_uri() (in module airflow.providers.trino.assets.trino) SCHEMA (in module tests.system.trino.example_trino) schema_fields (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute)

schema_object (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) source_bucket (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) source_object (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) strip_semicolon (airflow.providers.trino.hooks.trino.TrinoHook attribute)

T

T (in module airflow.providers.trino.hooks.trino) TABLE (in module tests.system.trino.example_trino) TABLE1 (in module tests.system.trino.example_trino) TABLE2 (in module tests.system.trino.example_trino) template_fields (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) test_run (in module tests.system.trino.example_gcs_to_trino) (in module tests.system.trino.example_trino) tests.system.trino module

tests.system.trino.example_gcs_to_trino module tests.system.trino.example_trino module trino_conn_id (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) trino_create_schema (in module tests.system.trino.example_trino) trino_table (airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator attribute) TRINO_TABLE (in module tests.system.trino.example_gcs_to_trino) TrinoException TrinoHook (class in airflow.providers.trino.hooks.trino)

PreviousNext

Was this entry helpful?