• Home
• Index

Index

_

__mapper_args__ (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

__version__ (in module airflow.providers.common.sql)

A

airflow.providers.common.sql module airflow.providers.common.sql.hooks module airflow.providers.common.sql.hooks.handlers module airflow.providers.common.sql.hooks.sql module airflow.providers.common.sql.operators module

airflow.providers.common.sql.operators.sql module airflow.providers.common.sql.sensors module airflow.providers.common.sql.sensors.sql module AIRFLOW_DB_METADATA_TABLE (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query)

B

BaseSQLOperator (class in airflow.providers.common.sql.operators.sql) BranchSQLOperator (class in airflow.providers.common.sql.operators.sql)

bulk_dump() (airflow.providers.common.sql.hooks.sql.DbApiHook method) bulk_load() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

C

check_value() (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator method) column_check (in module tests.system.common.sql.example_sql_column_table_check) column_checks (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) conn_id_field (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) conn_name_attr (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) connect() (airflow.providers.common.sql.hooks.sql.ConnectorProtocol method) connection (airflow.providers.common.sql.hooks.sql.DbApiHook property)

connection_args (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query) (in module tests.system.common.sql.example_sql_threshold_check) connection_extra (airflow.providers.common.sql.hooks.sql.DbApiHook property) connection_extra_lower() (airflow.providers.common.sql.hooks.sql.DbApiHook method) connector (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) ConnectorProtocol (class in airflow.providers.common.sql.hooks.sql)

D

DbApiHook (class in airflow.providers.common.sql.hooks.sql)

default_conn_name (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) default_output_processor() (in module airflow.providers.common.sql.operators.sql)

E

execute() (airflow.providers.common.sql.operators.sql.BranchSQLOperator method) (airflow.providers.common.sql.operators.sql.SQLCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator method)

execute_query (in module tests.system.common.sql.example_sql_execute_query)

F

fetch_all_handler() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql)

fetch_one_handler() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql)

G

get_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_conn() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_conn_id() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_cursor() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_db_hook() (airflow.providers.common.sql.operators.sql.BaseSQLOperator method) get_db_log_messages() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_first() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_hook() (airflow.providers.common.sql.operators.sql.BaseSQLOperator class method) get_openlineage_authority_part() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) get_openlineage_database_dialect() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

get_openlineage_database_info() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_database_specific_lineage() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_default_schema() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_facets_on_complete() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) get_openlineage_facets_on_start() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) get_pandas_df() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_pandas_df_by_chunks() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_records() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_sqlalchemy_engine() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_uri() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

I

insert_rows() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

inspector (airflow.providers.common.sql.hooks.sql.DbApiHook property)

L

last_description (airflow.providers.common.sql.hooks.sql.DbApiHook property)

M

module airflow.providers.common.sql airflow.providers.common.sql.hooks airflow.providers.common.sql.hooks.handlers airflow.providers.common.sql.hooks.sql airflow.providers.common.sql.operators airflow.providers.common.sql.operators.sql airflow.providers.common.sql.sensors airflow.providers.common.sql.sensors.sql tests.system.common.sql tests.system.common.sql.example_sql_column_table_check tests.system.common.sql.example_sql_execute_query tests.system.common.sql.example_sql_threshold_check

P

placeholder() (airflow.providers.common.sql.hooks.sql.DbApiHook method) poke() (airflow.providers.common.sql.sensors.sql.SqlSensor method)

prepare_template() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) push() (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator method)

R

ratio_formulas (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) return_single_query_results() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql)

run() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

S

set_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) split_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) sql_check_template (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) SQL_PLACEHOLDERS (in module airflow.providers.common.sql.hooks.sql) sqlalchemy_url (airflow.providers.common.sql.hooks.sql.DbApiHook property) SQLCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLColumnCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLExecuteQueryOperator (class in airflow.providers.common.sql.operators.sql)

SQLIntervalCheckOperator (class in airflow.providers.common.sql.operators.sql) SqlSensor (class in airflow.providers.common.sql.sensors.sql) SQLTableCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLThresholdCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLValueCheckOperator (class in airflow.providers.common.sql.operators.sql) strip_semicolon (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) strip_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) supports_autocommit (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) supports_executemany (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

T

T (in module airflow.providers.common.sql.hooks.sql) template_ext (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) template_fields (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) template_fields_renderers (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

test_connection() (airflow.providers.common.sql.hooks.sql.DbApiHook method) test_run (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query) (in module tests.system.common.sql.example_sql_threshold_check) tests.system.common.sql module tests.system.common.sql.example_sql_column_table_check module tests.system.common.sql.example_sql_execute_query module tests.system.common.sql.example_sql_threshold_check module threshhold_check (in module tests.system.common.sql.example_sql_threshold_check)

U

ui_color (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute)

ui_fgcolor (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute)

W

WARNING_MESSAGE (in module airflow.providers.common.sql.hooks.sql)

PreviousNext

Was this entry helpful?