Structs§
- Categorizer
- Transformer
Action - The Action that a transformer should take on the plan.
Enums§
Functions§
- get_
aggr_ func - get_
aggr_ func_ mut - is_
all_ aggr_ exprs_ steppable - Check if the given aggregate expression is steppable.
As in if it can be split into multiple steps:
i.e. on datanode first call
state(input)then on frontend callcalc(merge(state))to get the final result. - partial_
commutative_ transformer - step_
aggr_ to_ upper_ aggr - generate the upper aggregation plan that will execute on the frontend. Basically a logical plan resembling the following: Projection: Aggregate:
Type Aliases§
- Stage
Transformer - Returns transformer action that need to be applied
- Transformer