public SingleOutputStreamOperator < T > min ( int positionToMin ) { return aggregate ( new ComparableAggregator <> ( positionToMin , input . getType ( ) , AggregationFunction . AggregationType . MIN , input . getExecutionConfig ( ) ) ) ; }
Applies an aggregation that that gives the minimum value of every window of the data stream at the given position .