easy_sql.cli.backend_processor

Module Contents

Classes

BackendProcessor

BigqueryBackendProcessor

ClickhouseBackendProcessor

FlinkBackendProcessor

MaxComputeBackendProcessor

PostgresBackendProcessor

SparkBackendProcessor

class easy_sql.cli.backend_processor.BackendProcessor(config)
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

static create_backend_processor(config)
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

Return type

BackendProcessor

run(self, vars=None, dry_run=False, backend_config=None)
Parameters
  • vars (Optional[str]) –

  • dry_run (bool) –

  • backend_config (Optional[List[str]]) –

shell_command(self, vars_arg, dry_run_arg, entry_file, backend_config, **kwargs)
Parameters
  • vars_arg (Optional[str]) –

  • dry_run_arg (str) –

  • entry_file (str) –

  • backend_config (Optional[List[str]]) –

Return type

str

class easy_sql.cli.backend_processor.BigqueryBackendProcessor(config)

Bases: BackendProcessor

digraph inheritancef3ca548380 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "BigqueryBackendProcessor" [URL="#easy_sql.cli.backend_processor.BigqueryBackendProcessor",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"]; "BackendProcessor" -> "BigqueryBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

class easy_sql.cli.backend_processor.ClickhouseBackendProcessor(config)

Bases: BackendProcessor

digraph inheritance46dbbc7407 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "ClickhouseBackendProcessor" [URL="#easy_sql.cli.backend_processor.ClickhouseBackendProcessor",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"]; "BackendProcessor" -> "ClickhouseBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

class easy_sql.cli.backend_processor.FlinkBackendProcessor(config)

Bases: BackendProcessor

digraph inheritance5bd1a598c9 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "FlinkBackendProcessor" [URL="#easy_sql.cli.backend_processor.FlinkBackendProcessor",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"]; "BackendProcessor" -> "FlinkBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

shell_command(self, vars_arg, dry_run_arg, entry_file, backend_config)
Parameters
  • vars_arg (Optional[str]) –

  • dry_run_arg (str) –

  • entry_file (str) –

  • backend_config (Optional[List[str]]) –

Return type

str

class easy_sql.cli.backend_processor.MaxComputeBackendProcessor(config)

Bases: BackendProcessor

digraph inheritancef9d05a360f { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "MaxComputeBackendProcessor" [URL="#easy_sql.cli.backend_processor.MaxComputeBackendProcessor",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"]; "BackendProcessor" -> "MaxComputeBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

class easy_sql.cli.backend_processor.PostgresBackendProcessor(config)

Bases: BackendProcessor

digraph inheritance8bf60f56ff { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "PostgresBackendProcessor" [URL="#easy_sql.cli.backend_processor.PostgresBackendProcessor",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"]; "BackendProcessor" -> "PostgresBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

class easy_sql.cli.backend_processor.SparkBackendProcessor(config)

Bases: BackendProcessor

digraph inheritance4786833dac { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "BackendProcessor" [URL="#easy_sql.cli.backend_processor.BackendProcessor",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"]; "SparkBackendProcessor" [URL="#easy_sql.cli.backend_processor.SparkBackendProcessor",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"]; "BackendProcessor" -> "SparkBackendProcessor" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

config (easy_sql.config.sql_config.EasySqlConfig) –

shell_command(self, vars_arg, dry_run_arg, entry_file, backend_config, spark_submit=None)
Parameters
  • vars_arg (Optional[str]) –

  • dry_run_arg (str) –

  • entry_file (str) –

  • backend_config (Optional[List[str]]) –

  • spark_submit (Optional[str]) –

Return type

str