[streaming] DataStream fix to return DataStreamSink on closing operators
[streaming] GroupReduce operator added + StreamCollector bugfix