• 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.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.providers.common.sql.example_sql_column_table_check) (in module tests.system.providers.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.providers.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_args (in module tests.system.providers.common.sql.example_sql_column_table_check) (in module tests.system.providers.common.sql.example_sql_execute_query) 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)

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.providers.common.sql.example_sql_execute_query)

F

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

fetch_one_handler() (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_cursor() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_db_hook() (airflow.providers.common.sql.operators.sql.BaseSQLOperator method) get_first() (airflow.providers.common.sql.hooks.sql.DbApiHook 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)

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.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.providers.common.sql tests.system.providers.common.sql.example_sql_column_table_check tests.system.providers.common.sql.example_sql_execute_query

P

placeholder (airflow.providers.common.sql.hooks.sql.DbApiHook property) 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.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) 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_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) supports_autocommit (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.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.providers.common.sql.example_sql_column_table_check) (in module tests.system.providers.common.sql.example_sql_execute_query) tests.system.providers.common.sql module tests.system.providers.common.sql.example_sql_column_table_check module tests.system.providers.common.sql.example_sql_execute_query module

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)

PreviousNext

Was this entry helpful?