特牛网址导航

Flink多流转换 完整使用 (第八章)_flink singleoutputstreamoperator list测流输出-CSDN博客

网友收藏
文章浏览阅读693次。多流转换是流处理在实际应用中常见的需求,主要包括分流和合流两大类,本章分别做了详细讲解。在Flink中,分流操作可以通过处理函数的侧输出流(side output)很容易地实现;而合流则提供不同层级的各种API。最基本的合流方式是联合(union)和连接(connect),两者的主要区别在于union可以对多条流进行合并,数据类型必须一致;而connect只能连接两条流,数据类型可以不同。事实上connect提供了最底层的处理函数(process function)接口。_flink singleoutputstreamoperator list测流输出