Module task 

Structs

BatchingTask

PlanInfo

TableDef 🔒

TaskArgs

Arguments for creating batching task

TaskConfig

The task’s config, immutable once created

Enums

QueryType

Functions

build_by_sql_schema 🔒

simply build by schema, return first timestamp column and no primary key

build_by_tql_schema 🔒

Return first timestamp column found in output schema and all string columns

build_pk_from_aggr 🔒

Return first timestamp column which is in group by clause and other columns which are also in group by clause

create_table_with_expr 🔒

determine_query_type 🔒

is_merge_mode_last_non_null 🔒