Struct dataflow_types::plan::reduce::CollationPlan [−][src]
pub struct CollationPlan {
pub accumulable: Option<AccumulablePlan>,
pub hierarchical: Option<HierarchicalPlan>,
pub basic: Option<BasicPlan>,
pub aggregate_types: Vec<ReductionType>,
}
Expand description
Plan for collating the results of computing multiple aggregation types.
TODO: could we express this as a delta join
Fields
accumulable: Option<AccumulablePlan>
Accumulable aggregation results to collate, if any.
hierarchical: Option<HierarchicalPlan>
Hierarchical aggregation results to collate, if any.
basic: Option<BasicPlan>
Basic aggregation results to collate, if any.
aggregate_types: Vec<ReductionType>
When we get results back from each of the different aggregation types, they will be subsequences of the sequence aggregations in the original reduce expression. We keep a map from output position -> reduction type to easily merge results back into the requested order.
Trait Implementations
Returns the “default value” for a type. Read more
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 CollationPlan
impl Send for CollationPlan
impl Sync for CollationPlan
impl Unpin for CollationPlan
impl UnwindSafe for CollationPlan
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