easy_sql.sql_processor.backend.maxcompute

Module Contents

Classes

MaxComputeBackend

MaxComputeRow

MaxComputeTable

PartitionMode

Generic enumeration.
class easy_sql.sql_processor.backend.maxcompute.MaxComputeBackend(sql_expr, **kwargs)

Bases: easy_sql.sql_processor.backend.base.Backend

digraph inheritance6dac3accaa { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "Backend" [URL="../base/index.html#easy_sql.sql_processor.backend.base.Backend",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"]; "MaxComputeBackend" [URL="#easy_sql.sql_processor.backend.maxcompute.MaxComputeBackend",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"]; "Backend" -> "MaxComputeBackend" [arrowsize=0.5,style="setlinewidth(0.5)"]; }
Parameters

sql_expr (Optional[easy_sql.sql_processor.backend.rdb.SqlExpr]) –

append_temp_view(self, view_name)
broadcast_table(self, table, name)
Parameters
clean(self)
clear_cache(self)
clear_temp_tables(self, exclude=None)
Parameters

exclude (List[str]) –

create_cache_table(self, table, name)
Parameters
create_empty_table(self)
create_temp_table(self, table, name)
Parameters
exec_native_sql(self, sql)
Parameters

sql (str) –

Return type

Any

exec_sql(self, sql)
Parameters

sql (str) –

Return type

MaxComputeTable

get_table(self, table_name)
init_udfs(self, *args, **kwargs)
refresh_table_partitions(self, table)
Parameters

table (easy_sql.sql_processor.backend.base.TableMeta) –

register_udfs(self, funcs)
Parameters

funcs (Dict[str, Callable]) –

save_table(self, source_table_meta, target_table_meta, save_mode, create_target_table)
Parameters
table_exists(self, table)
Parameters

table (easy_sql.sql_processor.backend.base.TableMeta) –

temp_tables(self)
Return type

List[str]

class easy_sql.sql_processor.backend.maxcompute.MaxComputeRow(schema, values)

Bases: easy_sql.sql_processor.backend.base.Row

digraph inheritancefaf28d3908 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "MaxComputeRow" [URL="#easy_sql.sql_processor.backend.maxcompute.MaxComputeRow",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"]; "Row" -> "MaxComputeRow" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Row" [URL="../base/index.html#easy_sql.sql_processor.backend.base.Row",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"]; }
Parameters

values (Optional[Tuple]) –

as_dict(self)
as_tuple(self)
Return type

Tuple

static from_schema_meta(cols, types, values, pt_cols=None, pt_types=None)
Parameters

  • cols (List[str]) –

  • types (List[str]) –

  • values (Optional[Tuple]) –

  • pt_cols (List[str]) –

  • pt_types (List[str]) –

class easy_sql.sql_processor.backend.maxcompute.MaxComputeTable(backend, sql, table_name=None)

Bases: easy_sql.sql_processor.backend.base.Table

digraph inheritance77f235368a { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "MaxComputeTable" [URL="#easy_sql.sql_processor.backend.maxcompute.MaxComputeTable",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"]; "Table" -> "MaxComputeTable" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Table" [URL="../base/index.html#easy_sql.sql_processor.backend.base.Table",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"]; }
Parameters
collect(self, count=1000)
Parameters

count (int) –

Return type

List[easy_sql.sql_processor.backend.base.Row]

count(self)
Return type

int

field_names(self)
Return type

List[str]

field_types(self)
Return type

List[str]

first(self)
Return type

MaxComputeRow

static from_table_meta(backend, table_meta)
Parameters

table_meta (easy_sql.sql_processor.backend.base.TableMeta) –

is_empty(self)
Return type

bool

limit(self, count)
Parameters

count (int) –

Return type

MaxComputeTable

save_to_table(self, target_table_meta, save_mode=SaveMode.overwrite)
Parameters
Return type

None

show(self, count=20)
Parameters

count (int) –

with_column(self, name, value)
Parameters

  • name (str) –

  • value (any) –

Return type

MaxComputeTable

class easy_sql.sql_processor.backend.maxcompute.PartitionMode

Bases: enum.Enum

digraph inheritancea4ff146a95 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "Enum" [fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",tooltip="Generic enumeration."]; "PartitionMode" [URL="#easy_sql.sql_processor.backend.maxcompute.PartitionMode",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"]; "Enum" -> "PartitionMode" [arrowsize=0.5,style="setlinewidth(0.5)"]; }

Generic enumeration.

Derive from this class to define new enumerations.

ALL_DYNAMIC = [0]
ALL_STATIC = [1]
HYBRID = 2