首页 笔记 图片 查字 
所属分类:Flink
浏览:111
内容:

侧输出流在Flink中叫作SideOutput,用途类似于DataStream#split,本质上是将一个数据流按照条件切分为多个子数据流,子数据流叫作 侧输出流/旁路输出 数据流,每个旁路输出数据流可以有自己的下游处理逻辑。


作用:

对数据流进行分割,但又不会复制数据流的一种分流机制。

对延迟迟到的数据进行处理,可以不用丢弃迟到数据。

能有效解决Split算子不能进行连续分流的问题。


final OutputTag<String> sideOutputTag1 = new OutputTag<String>("sideOutput1") {};

ctx.output(sideOutputTag1, "sideout1-" + String.valueOf(value));

mainDataStream.getSideOutput(sideOutputTag1).print();


参考:

blog.csdn.net/zg_hover/article/details/123786066

blog.csdn.net/weixin_43857464/article/details/110824937