[streaming] GroupReduce operator added + StreamCollector bugfix