easy_sql.sql_processor.funcs_common
Module Contents
Classes
- class easy_sql.sql_processor.funcs_common.AlertFunc(backend, alerter)
- Parameters
backend (Optional[easy_sql.sql_processor.backend.Backend]) –
alerter (Alerter) –
- alert(self, step, context, rule_name, pass_condition, alert_template, mentioned_users)
- Parameters
step (easy_sql.sql_processor.step.Step) –
context (easy_sql.sql_processor.context.ProcessorContext) –
rule_name (str) –
pass_condition (str) –
alert_template (str) –
mentioned_users (str) –
- alert_exception_handler(self, rule_name, mentioned_users)
- alert_with_backend(self, backend, step, context, rule_name, pass_condition, alert_template, mentioned_users)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
step (easy_sql.sql_processor.step.Step) –
context (easy_sql.sql_processor.context.ProcessorContext) –
rule_name (str) –
pass_condition (str) –
alert_template (str) –
mentioned_users (str) –
- class easy_sql.sql_processor.funcs_common.AnalyticsFuncs(backend)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
- class easy_sql.sql_processor.funcs_common.ColumnFuncs(backend)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
- all_cols_prefixed_with_exclusion_expr(self, table_name, prefix, *cols_to_exclude)
- all_cols_with_exclusion_expr(self, table_name, *cols_to_exclude)
- class easy_sql.sql_processor.funcs_common.PartitionFuncs(backend)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
- ensure_dwd_partition_exists(self, step, table_name, partition_value, *foreign_key_cols)
- Parameters
step (easy_sql.sql_processor.step.Step) –
table_name (str) –
partition_value (str) –
- Return type
- ensure_partition_exists(self, step, *args)
- Parameters
step (easy_sql.sql_processor.step.Step) –
- Return type
- ensure_partition_or_first_partition_exists(self, step, *args)
- Parameters
step (easy_sql.sql_processor.step.Step) –
- Return type
- ensure_table_partition_exists(self, step, partition_value, table, *tables)
- Parameters
step (easy_sql.sql_processor.step.Step) –
partition_value (str) –
table (str) –
tables (str) –
- Return type
- ensure_table_partition_or_first_partition_exists(self, step, partition_value, table, *tables)
- Parameters
step (easy_sql.sql_processor.step.Step) –
partition_value (str) –
table (str) –
tables (str) –
- Return type
- get_first_partition_optional(self, table_name)
- get_partition_or_first_partition(self, table_name, partition_value)
- is_first_partition(self, table_name, partition_value)
- is_not_first_partition(self, table_name, partition_value)
- partition_exists(self, table_name, partition_value)
- partition_not_exists(self, table_name, partition_value)
- class easy_sql.sql_processor.funcs_common.TableFuncs(backend)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
- check_not_null_column_in_table(self, step, table_name, not_null_column, query=None)
- Parameters
step (easy_sql.sql_processor.step.Step) –
table_name (str) –
not_null_column (str) –
query (Optional[str]) –
- Return type
- ensure_no_null_data_in_table(self, step, table_name, query=None)
- Parameters
step (easy_sql.sql_processor.step.Step) –
table_name (str) –
query (Optional[str]) –
- Return type