public SingleOutputStreamOperator < T > sum ( String field ) { return aggregate ( new SumAggregator <> ( field , input . getType ( ) , input . getExecutionConfig ( ) ) ) ; }
Applies an aggregation that sums every window of the pojo data stream at the given field for every window .