Struct dataflow_types::plan::reduce::AccumulablePlan [−][src]
pub struct AccumulablePlan {
pub full_aggrs: Vec<AggregateExpr>,
pub simple_aggrs: Vec<(usize, usize, AggregateExpr)>,
pub distinct_aggrs: Vec<(usize, usize, AggregateExpr)>,
}
Expand description
Plan for computing a set of accumulable aggregations.
We fuse all of the accumulable aggregations together and compute them with one dataflow fragment. We need to be careful to separate out the aggregations that apply only to the distinct set of values. We need to apply a distinct operator to those before we combine them with everything else.
Fields
full_aggrs: Vec<AggregateExpr>
All of the aggregations we were asked to compute, stored in order.
simple_aggrs: Vec<(usize, usize, AggregateExpr)>
All of the non-distinct accumulable aggregates. Each element represents: (index of the aggregation among accumulable aggregations, index of the datum among inputs, aggregation expr) These will all be rendered together in one dataflow fragment.
distinct_aggrs: Vec<(usize, usize, AggregateExpr)>
Same as above but for all of the DISTINCT
accumulable aggregations.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for AccumulablePlan
impl Send for AccumulablePlan
impl Sync for AccumulablePlan
impl Unpin for AccumulablePlan
impl UnwindSafe for AccumulablePlan
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