[streaming] CoFlatMap & CoGroupReduce functionality
Merge resolved