• 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

accept_none (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) airflow.providers.common.sql module airflow.providers.common.sql.dialects module airflow.providers.common.sql.dialects.dialect module airflow.providers.common.sql.get_provider_info 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) autocommit (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute)

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) checks (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) column_check (in module tests.system.common.sql.example_sql_column_table_check) column_checks (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) column_mapping (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) conn_id (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor 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 property) connector (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) ConnectorProtocol (class in airflow.providers.common.sql.hooks.sql)

D

database (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) date_filter_column (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) days_back (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) 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) descriptions (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) dialect (airflow.providers.common.sql.hooks.sql.DbApiHook property) Dialect (class in airflow.providers.common.sql.dialects.dialect) dialect_name (airflow.providers.common.sql.hooks.sql.DbApiHook property)

E

escape_column_names (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) escape_word() (airflow.providers.common.sql.dialects.dialect.Dialect method) escape_word_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) 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) extract_schema_from_table() (airflow.providers.common.sql.dialects.dialect.Dialect class method)

F

fail_on_empty (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) failure (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) 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) follow_task_ids_if_false (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) follow_task_ids_if_true (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute)

G

generate_insert_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) generate_replace_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_column_names() (airflow.providers.common.sql.dialects.dialect.Dialect 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_primary_keys() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_provider_info() (in module airflow.providers.common.sql.get_provider_info) get_records() (airflow.providers.common.sql.dialects.dialect.Dialect method) (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_reserved_words() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_sqlalchemy_engine() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_target_fields() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_uri() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

H

handler (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) has_tolerance (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

hook (airflow.providers.common.sql.dialects.dialect.Dialect attribute) hook_params (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute)

I

ignore_zero (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) insert_rows() (airflow.providers.common.sql.hooks.sql.DbApiHook method) insert_statement_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

inspector (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

L

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

log_sql (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

M

max_threshold (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) metrics_sorted (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) metrics_thresholds (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) min_threshold (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) module airflow.providers.common.sql airflow.providers.common.sql.dialects airflow.providers.common.sql.dialects.dialect airflow.providers.common.sql.get_provider_info 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

parameters (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.sensors.sql.SqlSensor attribute) partition_clause (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute)

pass_value (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) pattern (airflow.providers.common.sql.dialects.dialect.Dialect attribute) placeholder (airflow.providers.common.sql.dialects.dialect.Dialect property) (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_formula (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) ratio_formulas (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) replace_statement_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) reserved_words (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

resolve_dialects() (in module airflow.providers.common.sql.hooks.sql) retry_on_failure (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) return_last (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator 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.dialects.dialect.Dialect method) (airflow.providers.common.sql.hooks.sql.DbApiHook method)

S

selector (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) set_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) show_return_value_in_logs (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) split_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) split_statements (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) sql (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.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) sql1 (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) sql2 (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) 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) success (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) 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.dialects.dialect) (in module airflow.providers.common.sql.hooks.sql) table (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) 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) tol (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

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) unescape_word() (airflow.providers.common.sql.dialects.dialect.Dialect method)

W

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

PreviousNext

Was this entry helpful?