Struct dataflow_types::plan::reduce::MonotonicPlan

pub struct MonotonicPlan {
    pub aggr_funcs: Vec<AggregateFunc>,
    pub skips: Vec<usize>,
}

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

impl Clone for MonotonicPlan

fn clone(&self) -> MonotonicPlan

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MonotonicPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MonotonicPlan

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for MonotonicPlan

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.