Struct dataflow_types::plan::reduce::MonotonicPlan [−][src]
pub struct MonotonicPlan {
pub aggr_funcs: Vec<AggregateFunc>,
pub skips: Vec<usize>,
}
Expand description
Plan for computing a set of hierarchical aggregations with a monotonic input.
Here, the aggregations will be rendered in place. We don’t need to worry about retractions because the inputs are append only, so we can change our computation to only retain the “best” value in the diff field, instead of holding onto all values.
Fields
aggr_funcs: Vec<AggregateFunc>
All of the aggregations we were asked to compute.
skips: Vec<usize>
Set of “skips” or calls to nth()
an iterator needs to do over
the input to extract the relevant datums.
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 MonotonicPlan
impl Send for MonotonicPlan
impl Sync for MonotonicPlan
impl Unpin for MonotonicPlan
impl UnwindSafe for MonotonicPlan
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