[ 笔记列表 ]
所属分类: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
链接:
|