docs: public SingleOutputStreamOperator<T> reduce(ReduceFunction<T> reducer) {
  		return transform("Keyed Reduce", getType(), new StreamGroupedReduce<T>(
  				clean(reducer), getType().createSerializer(getExecutionConfig())));
  	}