双数据流转换为单数据流操作的运算:cogroup, join和coflatmap
- Join:只输出条件匹配的元素对。
- CoGroup: 除了输出匹配的元素对以外,未能匹配的元素也会输出。
- CoFlatMap:没有匹配条件,不进行匹配,分别处理两个流的元素。
CoFlatMap
stream1数据到来时,会调用flatMap1方法,stream2收到数据之时,会调用flatMap2方法
双数据流转换为单数据流操作的运算:cogroup, join和coflatmap
- Join:只输出条件匹配的元素对。
- CoGroup: 除了输出匹配的元素对以外,未能匹配的元素也会输出。
- CoFlatMap:没有匹配条件,不进行匹配,分别处理两个流的元素。
stream1数据到来时,会调用flatMap1方法,stream2收到数据之时,会调用flatMap2方法
相关文章: