easy_sql.sql_processor_debugger

Module Contents

Classes

SqlProcessorDebugger

class easy_sql.sql_processor_debugger.SqlProcessorDebugger(sql_file_path, backend, vars=None, funcs=None, funcs_py_file=None, extra_cols=None, udf_py_file=None, scala_udf_initializer=None, templates=None)
Parameters
add_vars(self, vars)
Parameters

vars (Optional[Dict[str, Any]]) –

property current_step(self)
Return type

Optional[easy_sql.sql_processor.Step]

property current_step_no(self)
Return type

Optional[int]

property is_finished(self)
property is_inprogress(self)
Return type

bool

property is_started(self)
Return type

bool

property last_step(self)
Return type

Optional[easy_sql.sql_processor.Step]

property last_step_no(self)
Return type

Optional[int]

property left_step_count(self)
Return type

int

native_sql(self, sql)
Parameters

sql (str) –

Return type

Any

property next_step(self)
Return type

Optional[easy_sql.sql_processor.Step]

property next_step_no(self)
Return type

Optional[int]

print_steps(self)
refresh_initial_tempview(self)
report(self, verbose=True)
Parameters

verbose (bool) –

restart(self)
run(self)
run_to(self, step_no)
Parameters

step_no (int) –

set_spark_configs(self, configs)
Parameters

configs (Dict[str, str]) –

set_vars(self, vars)
Parameters

vars (Dict[str, Any]) –

showdf(self, table_name)
Parameters

table_name (str) –

sql(self, sql)
Parameters

sql (str) –

Return type

Any

step(self, step_no)
Parameters

step_no (int) –

Return type

Optional[easy_sql.sql_processor.Step]

step_on(self)
step_to(self, step_no)
Parameters

step_no (int) –

property templates(self)
Return type

Dict[str, str]

property tempviews(self)
Return type

List[str]

property vars(self)
Return type

Dict[str, Any]