Struct transform::reduction_pushdown::ReduceBuilder [−][src]
struct ReduceBuilder {
input: MirRelationExpr,
group_key: Vec<MirScalarExpr>,
aggregates: Vec<AggregateExpr>,
localize_map: HashMap<usize, usize>,
}
Expand description
Constructs a Reduce around a component, localizing column references.
Fields
input: MirRelationExpr
group_key: Vec<MirScalarExpr>
aggregates: Vec<AggregateExpr>
localize_map: HashMap<usize, usize>
Maps (global column relative to old join) -> (local column relative to input
)
Implementations
fn new(
component: Component,
inputs: &Vec<MirRelationExpr>,
old_join_mapper: &JoinInputMapper
) -> Self
fn construct_reduce(
self,
monotonic: bool,
expected_group_size: Option<usize>
) -> MirRelationExpr
Auto Trait Implementations
impl RefUnwindSafe for ReduceBuilder
impl Send for ReduceBuilder
impl Sync for ReduceBuilder
impl Unpin for ReduceBuilder
impl UnwindSafe for ReduceBuilder
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more