easy_sql.sql_processor.funcs_flink
Module Contents
Classes
- class easy_sql.sql_processor.funcs_flink.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_flink.AnalyticsFuncs(backend)
- Parameters
backend (easy_sql.sql_processor.backend.Backend) –
- class easy_sql.sql_processor.funcs_flink.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_flink.ParallelismFuncs(flink)
- Parameters
- class easy_sql.sql_processor.funcs_flink.StreamingFuncs(flink)
- Parameters
- execute_streaming_inserts(self)
- class easy_sql.sql_processor.funcs_flink.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
- class easy_sql.sql_processor.funcs_flink.TestFuncs(flink)
Bases:
digraph inheritancea645f0ecb5 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "TestFuncs" [fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled"]; "TestFuncs" [URL="#easy_sql.sql_processor.funcs_flink.TestFuncs",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "TestFuncs" -> "TestFuncs" [arrowsize=0.5,style="setlinewidth(0.5)"]; }easy_sql.sql_processor.funcs_common.TestFuncs
- Parameters
- exec_sql_in_source(self, step, db, connector)
- Parameters
step (easy_sql.sql_processor.step.Step) –
db (str) –
connector (str) –