Enum dataflow_types::plan::reduce::BasicPlan [−][src]
pub enum BasicPlan {
Single(usize, AggregateExpr),
Multiple(Vec<(usize, AggregateExpr)>),
}
Expand description
Plan for computing a set of basic aggregations.
There’s much less complexity when rendering basic aggregations. Each aggregation corresponds to one Differential reduce operator. That’s it. However, we still want to present one final arrangement so basic aggregations present results with the same interface (one arrangement containing a row with all results) that accumulable and hierarchical aggregations do. To provide that, we render an additional reduce operator whenever we have multiple reduce aggregates to combine and present results in the appropriate order. If we were only asked to compute a single aggregation, we can skip that step and return the arrangement provided by computing the aggregation directly.
Variants
Single(usize, AggregateExpr)
Plan for rendering a single basic aggregation. Here, the first element denotes the index in the set of inputs that we are aggregating over.
Multiple(Vec<(usize, AggregateExpr)>)
Tuple Fields
0: Vec<(usize, AggregateExpr)>
Plan for rendering multiple basic aggregations.
These need to then be collated together in an additional
reduction. Each element represents the:
(index of the set of the input we are aggregating over, the aggregation function)
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 BasicPlan
impl UnwindSafe for BasicPlan
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