[streaming] reduce operator added to DataStream and ConnectedDataStream + grouped batch and windowReduce operators reworked