Flink双流操做

简介 Flink 双数据流转换为单数据流操做的运算有cogroup, join和coflatmap。下面为你们对比介绍下这3个运算的功能和用法。java Join：只输出条件匹配的元素对。 CoGroup: 除了输出匹配的元素对之外，未能匹配的元素也会输出。 CoFlatMap：没有匹配条件，不进行匹配，分别处理两个流的元素。在此基础上彻底能够实现join和cogroup的功能，比他们使用上更加自

>>阅读原文<<