• Home
• Index

Index

_

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

__post_init__() (airflow.providers.common.sql.config.DataSourceConfig method) __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.config module airflow.providers.common.sql.datafusion module airflow.providers.common.sql.datafusion.base module airflow.providers.common.sql.datafusion.engine module airflow.providers.common.sql.datafusion.exceptions module airflow.providers.common.sql.datafusion.format_handlers module airflow.providers.common.sql.datafusion.object_storage_provider module airflow.providers.common.sql.decorators module airflow.providers.common.sql.decorators.analytics module airflow.providers.common.sql.decorators.sql module airflow.providers.common.sql.dialects module airflow.providers.common.sql.dialects.dialect module airflow.providers.common.sql.example_dags module airflow.providers.common.sql.example_dags.example_analytics 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.lineage module airflow.providers.common.sql.hooks.sql module airflow.providers.common.sql.operators module airflow.providers.common.sql.operators.analytics module airflow.providers.common.sql.operators.generic_transfer module airflow.providers.common.sql.operators.sql module airflow.providers.common.sql.sensors module airflow.providers.common.sql.sensors.sql module airflow.providers.common.sql.triggers module airflow.providers.common.sql.triggers.sql module airflow.providers.common.sql.version_compat 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) (in module tests.system.common.sql.example_sql_insert_rows) AIRFLOW_V_3_0_PLUS (in module airflow.providers.common.sql.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.common.sql.version_compat) analytics_task() (in module airflow.providers.common.sql.decorators.analytics) analytics_with_s3 (in module airflow.providers.common.sql.example_dags.example_analytics) AnalyticsOperator (class in airflow.providers.common.sql.operators.analytics) autocommit (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) AVRO (airflow.providers.common.sql.config.FormatType attribute) AvroFormatHandler (class in airflow.providers.common.sql.datafusion.format_handlers)

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) column_names (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator property) columns (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator property) conn_id (airflow.providers.common.sql.config.ConnectionConfig attribute) (airflow.providers.common.sql.config.DataSourceConfig attribute) (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger 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_generic_transfer) (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_insert_rows) (in module tests.system.common.sql.example_sql_threshold_check) (in module tests.system.common.sql.example_sql_value_check)

connection_extra (airflow.providers.common.sql.hooks.sql.DbApiHook property) connection_extra_lower (airflow.providers.common.sql.hooks.sql.DbApiHook property) ConnectionConfig (class in airflow.providers.common.sql.config) connector (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) ConnectorProtocol (class in airflow.providers.common.sql.hooks.sql) create_engine (in module airflow.providers.common.sql.hooks.sql) create_object_store() (airflow.providers.common.sql.datafusion.base.ObjectStorageProvider method) (airflow.providers.common.sql.datafusion.object_storage_provider.LocalObjectStorageProvider method) (airflow.providers.common.sql.datafusion.object_storage_provider.S3ObjectStorageProvider method) credentials (airflow.providers.common.sql.config.ConnectionConfig attribute) CSV (airflow.providers.common.sql.config.FormatType attribute) CsvFormatHandler (class in airflow.providers.common.sql.datafusion.format_handlers)

D

database (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) DataFusionEngine (class in airflow.providers.common.sql.datafusion.engine) datasource_config (airflow.providers.common.sql.datafusion.base.FormatHandler attribute) datasource_config_iceberg (in module airflow.providers.common.sql.example_dags.example_analytics) datasource_config_local (in module airflow.providers.common.sql.example_dags.example_analytics) datasource_config_s3 (in module airflow.providers.common.sql.example_dags.example_analytics) datasource_configs (airflow.providers.common.sql.operators.analytics.AnalyticsOperator attribute) DataSourceConfig (class in airflow.providers.common.sql.config) date_filter_column (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) days_back (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) db_name (airflow.providers.common.sql.config.DataSourceConfig 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) destination_conn_id (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) destination_hook (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer property) destination_hook_params (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) destination_table (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) df_ctx (airflow.providers.common.sql.datafusion.engine.DataFusionEngine 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) do_xcom_push (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute)

E

engine (airflow.providers.common.sql.operators.analytics.AnalyticsOperator attribute) 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.analytics.AnalyticsOperator method) (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) (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.SQLInsertRowsOperator 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_complete() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) execute_query (in module tests.system.common.sql.example_sql_execute_query) execute_query() (airflow.providers.common.sql.datafusion.engine.DataFusionEngine method) extra_config (airflow.providers.common.sql.config.ConnectionConfig attribute) 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)

FileFormatRegistrationException follow_branch (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) 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) format (airflow.providers.common.sql.config.DataSourceConfig attribute) FormatHandler (class in airflow.providers.common.sql.datafusion.base) FormatType (class in airflow.providers.common.sql.config)

G

generate_insert_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) generate_replace_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) GenericTransfer (class in airflow.providers.common.sql.operators.generic_transfer) get_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_bucket() (airflow.providers.common.sql.datafusion.base.ObjectStorageProvider 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_df() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_df_by_chunks() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_first() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_format (airflow.providers.common.sql.datafusion.base.FormatHandler property) (airflow.providers.common.sql.datafusion.format_handlers.AvroFormatHandler property) (airflow.providers.common.sql.datafusion.format_handlers.CsvFormatHandler property) (airflow.providers.common.sql.datafusion.format_handlers.IcebergFormatHandler property) (airflow.providers.common.sql.datafusion.format_handlers.ParquetFormatHandler property) get_format_handler() (in module airflow.providers.common.sql.datafusion.format_handlers) get_hook() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer class method) (airflow.providers.common.sql.operators.sql.BaseSQLOperator class method) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method) get_object_storage_provider() (in module airflow.providers.common.sql.datafusion.object_storage_provider) 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.BaseSQLOperator method) get_openlineage_facets_on_start() (airflow.providers.common.sql.operators.sql.BaseSQLOperator method) get_paginated_sql() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer 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_row_count() (in module airflow.providers.common.sql.hooks.handlers) get_schema() (airflow.providers.common.sql.datafusion.engine.DataFusionEngine method) get_scheme() (airflow.providers.common.sql.datafusion.base.ObjectStorageProvider method) (airflow.providers.common.sql.datafusion.object_storage_provider.LocalObjectStorageProvider method) (airflow.providers.common.sql.datafusion.object_storage_provider.S3ObjectStorageProvider method) get_sqlalchemy_engine() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_storage_type (airflow.providers.common.sql.datafusion.base.ObjectStorageProvider property) (airflow.providers.common.sql.datafusion.object_storage_provider.LocalObjectStorageProvider property) (airflow.providers.common.sql.datafusion.object_storage_provider.S3ObjectStorageProvider property) get_table_schema() (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) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger attribute)

I

ICEBERG (airflow.providers.common.sql.config.FormatType attribute) IcebergFormatHandler (class in airflow.providers.common.sql.datafusion.format_handlers) IcebergRegistrationException ignore_zero (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) ignored_columns (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) insert_args (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute)

insert_rows (in module tests.system.common.sql.example_sql_insert_rows) 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) is_table_provider (airflow.providers.common.sql.config.DataSourceConfig property)

K

KEY (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute)

L

last_description (airflow.providers.common.sql.hooks.sql.DbApiHook property) LOCAL (airflow.providers.common.sql.config.StorageType attribute)

LocalObjectStorageProvider (class in airflow.providers.common.sql.datafusion.object_storage_provider) log (in module airflow.providers.common.sql.hooks.lineage) log_sql (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

M

max_rows_check (airflow.providers.common.sql.operators.analytics.AnalyticsOperator attribute) 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.config airflow.providers.common.sql.datafusion airflow.providers.common.sql.datafusion.base airflow.providers.common.sql.datafusion.engine airflow.providers.common.sql.datafusion.exceptions airflow.providers.common.sql.datafusion.format_handlers airflow.providers.common.sql.datafusion.object_storage_provider airflow.providers.common.sql.decorators airflow.providers.common.sql.decorators.analytics airflow.providers.common.sql.decorators.sql airflow.providers.common.sql.dialects airflow.providers.common.sql.dialects.dialect airflow.providers.common.sql.example_dags airflow.providers.common.sql.example_dags.example_analytics airflow.providers.common.sql.get_provider_info airflow.providers.common.sql.hooks airflow.providers.common.sql.hooks.handlers airflow.providers.common.sql.hooks.lineage airflow.providers.common.sql.hooks.sql airflow.providers.common.sql.operators airflow.providers.common.sql.operators.analytics airflow.providers.common.sql.operators.generic_transfer airflow.providers.common.sql.operators.sql airflow.providers.common.sql.sensors airflow.providers.common.sql.sensors.sql airflow.providers.common.sql.triggers airflow.providers.common.sql.triggers.sql airflow.providers.common.sql.version_compat tests.system.common.sql tests.system.common.sql.example_generic_transfer tests.system.common.sql.example_sql_column_table_check tests.system.common.sql.example_sql_execute_query tests.system.common.sql.example_sql_insert_rows tests.system.common.sql.example_sql_threshold_check tests.system.common.sql.example_sql_value_check

O

ObjectStorageProvider (class in airflow.providers.common.sql.datafusion.base)

ObjectStoreCreationException options (airflow.providers.common.sql.config.DataSourceConfig attribute)

P

page_size (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) paginated_sql_statement_clause (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) 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.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) PARQUET (airflow.providers.common.sql.config.FormatType attribute) ParquetFormatHandler (class in airflow.providers.common.sql.datafusion.format_handlers) parse_boolean (in module airflow.providers.common.sql.operators.sql) 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) postoperator (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) preoperator (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) prepare_template() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) push() (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator method)

Q

queries (airflow.providers.common.sql.operators.analytics.AnalyticsOperator attribute)

QueryExecutionException

R

ratio_formula (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) ratio_formulas (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) register_data_source_format() (airflow.providers.common.sql.datafusion.base.FormatHandler method) (airflow.providers.common.sql.datafusion.format_handlers.AvroFormatHandler method) (airflow.providers.common.sql.datafusion.format_handlers.CsvFormatHandler method) (airflow.providers.common.sql.datafusion.format_handlers.IcebergFormatHandler method) (airflow.providers.common.sql.datafusion.format_handlers.ParquetFormatHandler method) register_datasource() (airflow.providers.common.sql.datafusion.engine.DataFusionEngine method) registered_tables (airflow.providers.common.sql.datafusion.engine.DataFusionEngine attribute) render_template_fields() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) replace_statement_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

requires_result_fetch (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) 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) result_output_format (airflow.providers.common.sql.operators.analytics.AnalyticsOperator attribute) 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) rows (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) run() (airflow.providers.common.sql.dialects.dialect.Dialect method) (airflow.providers.common.sql.hooks.sql.DbApiHook method) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method)

S

S3 (airflow.providers.common.sql.config.StorageType attribute) S3ObjectStorageProvider (class in airflow.providers.common.sql.datafusion.object_storage_provider) schema (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) selector (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) send_sql_hook_lineage() (in module airflow.providers.common.sql.hooks.lineage) serialize() (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method) session_context (airflow.providers.common.sql.datafusion.engine.DataFusionEngine property) set_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) show_return_value_in_logs (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) source_conn_id (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) source_hook (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer property) source_hook_params (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer 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.generic_transfer.GenericTransfer 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) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger attribute) (in module tests.system.common.sql.example_generic_transfer)

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) sql_task() (in module airflow.providers.common.sql.decorators.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) SQLExecuteQueryTrigger (class in airflow.providers.common.sql.triggers.sql) SQLInsertRowsOperator (class in airflow.providers.common.sql.operators.sql) SQLIntervalCheckOperator (class in airflow.providers.common.sql.operators.sql) SqlJobHookLineageExtra (class in airflow.providers.common.sql.hooks.lineage) 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) storage_type (airflow.providers.common.sql.config.DataSourceConfig attribute) StorageType (class in airflow.providers.common.sql.config) 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) table_name (airflow.providers.common.sql.config.DataSourceConfig attribute) (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator attribute) table_name_with_schema (airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator property) TABLE_PROVIDERS (in module airflow.providers.common.sql.config) template_ext (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (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.SQLInsertRowsOperator 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.analytics.AnalyticsOperator attribute) (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (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.SQLInsertRowsOperator 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.generic_transfer.GenericTransfer 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.SQLInsertRowsOperator 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_generic_transfer) (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_insert_rows) (in module tests.system.common.sql.example_sql_threshold_check) (in module tests.system.common.sql.example_sql_value_check) tests.system.common.sql module tests.system.common.sql.example_generic_transfer 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_insert_rows module tests.system.common.sql.example_sql_threshold_check module tests.system.common.sql.example_sql_value_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.generic_transfer.GenericTransfer attribute) (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) uri (airflow.providers.common.sql.config.DataSourceConfig attribute)

V

VALUE__DEFAULT_DB (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) VALUE__DEFAULT_SCHEMA (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) VALUE__EXTRA (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) VALUE__JOB_ID (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute)

VALUE__ROW_COUNT (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) VALUE__SQL_STATEMENT (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) VALUE__SQL_STATEMENT_PARAMETERS (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra attribute) value_check (in module tests.system.common.sql.example_sql_value_check) value_keys() (airflow.providers.common.sql.hooks.lineage.SqlJobHookLineageExtra class method)

W

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

PreviousNext

Was this entry helpful?