Module dataflow::render::reduce[−][src]

Expand description

Reduction dataflow construction.

Consult ReducePlan documentation for details.

Modules

Monoids for in-place compaction of monotonic streams.

Wraps an AccumInner with tracking of the total number of records observed, i.e., including null records.

Accumulates values for the various types of accumulable aggregations.

A type wrapping either an arrangement or a single collection.

Build the dataflow to compute and arrange multiple accumulable aggregations.

Build the dataflow to compute a single basic aggregation.

Build the dataflow to compute and arrange multiple non-accumulable, non-hierarchical aggregations on input.

Build the dataflow to compute and arrange multiple hierarchical aggregations on non-monotonic inputs.

Build the dataflow for one stage of a reduction tree for multiple hierarchical aggregates.

Build the dataflow to combine arrangements containing results of different aggregation types into a single arrangement.

Build the dataflow to compute the set of distinct keys.

Build the dataflow to compute the set of distinct keys.

Build the dataflow to compute and arrange multiple hierarchical aggregations on monotonic inputs.

Render a dataflow based on the provided plan.