Module pipeline

Structs

PipeLine

A pipeline consists of:

Functions

can_convert_to_hash_agg

create_pipeline

execute_pipeline

Executes all branches and replaces operators and sinks during execution to ensure we materialize.

get_dummy_operator

get_operator

get_sink

swap_join_order

Type Aliases

CallBacks