Skip to main content

build_threshold_basic

Function build_threshold_basic 

Source
pub fn build_threshold_basic<'scope, T: RenderTimestamp>(
    input: CollectionBundle<'scope, T>,
    key: Vec<MirScalarExpr>,
) -> CollectionBundle<'scope, T>
Expand description

Build a dataflow to threshold the input data.

This implementation maintains rows in the output, i.e. all rows that have a count greater than zero. It returns a CollectionBundle populated from a local arrangement.