Fink sideOutput 侧输出，优化

喜欢ヅ旅行 2022-01-22 20:06 108阅读 0赞

官网代码：

DataStream<Integer> input = ...;

final OutputTag<String> outputTag = new OutputTag<String>("side-output")\{\};

SingleOutputStreamOperator<Integer> mainDataStream = input  
  .process(new ProcessFunction<Integer, Integer>() \{

@Override  
      public void processElement(  
          Integer value,  
          Context ctx,  
          Collector<Integer> out) throws Exception \{  
        // emit data to regular output  
        out.collect(value);

// emit data to side output  
        ctx.output(outputTag, "sideout-" + String.valueOf(value));  
      \}  
    \});

使用代码：

final OutputTag<String> outputTag = new OutputTag<String>("side-output")\{\};

SingleOutputStreamOperator<Integer> mainDataStream = ...;

DataStream<String> sideOutputStream = mainDataStream.getSideOutput(outputTag);

参考路径：[https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/side\_output.html][https_ci.apache.org_projects_flink_flink-docs-release-1.6_dev_stream_side_output.html]

[https_ci.apache.org_projects_flink_flink-docs-release-1.6_dev_stream_side_output.html]: https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/side_output.html

发表评论取消回复

表情：

评论列表（有 0 条评论，108人围观）

还没有评论，来说两句吧...

相关阅读

相关 CoProcessFunction实战三部曲之三：定时器和侧输出

欢迎访问我的GitHub > 这里分类和汇总了欣宸的全部原创(含配套源码)：[https://github.com/zq2599/blog\_demos][https_g

朴灿烈づ我的快乐病毒、/ 2022年12月20日 12:45/ 0 赞/ 68 阅读

相关大数据之Flink(8) | 侧输出流（SideOutput）

大部分的DataStream API的算子的输出是单一输出，也就是某种数据类型的流。除了split算子，可以将一条流分成多条流，这些流的数据类型也都相同。process fun

忘是亡心i/ 2022年12月17日 04:27/ 0 赞/ 449 阅读

相关 Fink面试题

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

喜欢ヅ旅行/ 2022年11月06日 01:56/ 0 赞/ 39 阅读

相关 Flink——Side Output侧输出流

主要内容：结合应用场景，介绍Flink侧输出流的使用流程和原理在处理数据的时候，有时候想对不同情况的数据进行不同的处理，那么就需要把数据流进行分流。可以在主数据流

比眉伴天荒/ 2022年10月31日 04:29/ 0 赞/ 124 阅读

相关 Flink流处理（开窗、水印、侧输出流）

Flink流处理（开窗、水印、侧输出流）目录 Flink流处理（开窗、水印、侧输出流）一、Flink的window机制 1

秒速五厘米/ 2022年10月23日 14:29/ 1 赞/ 563 阅读

相关优化Eclipse控制台日志输出

-------------------- 版权声明本文原创作者：谷哥的小弟作者博客地址：http://blog.csdn.net/lfdfhl ---

深碍√TFBOYSˉ_/ 2022年10月10日 04:47/ 0 赞/ 230 阅读

相关资本侧和实体侧

\+关注改革开放以来中国的经济发展实践，实际上带来了两个重要结果。其一是中国经济的迅速崛起，创造了奇迹；其二是中国经济的资本化，中国经济已成资本化的市场经济，市场已经为资本

￡神魔★判官ぃ/ 2022年06月13日 09:26/ 0 赞/ 195 阅读

相关侧边框

效果图： ![Center][] ![Center 1][] 代码： <!DOCTYPE html

古城微笑少年丶/ 2022年06月07日 11:59/ 0 赞/ 142 阅读

相关 Fink sideOutput 侧输出，优化

官网代码： DataStream<Integer> input = ...; final OutputTag<String> outputTag = new OutputT

喜欢ヅ旅行/ 2022年01月22日 20:06/ 0 赞/ 109 阅读

相关 Flink 侧输出流拆分流应用

> 业务场景：使用Flink同步Kafka数据近实时写入MySQL，需要将登录数据拆分为登录，日活，新增分别入三个MySQL表。采用侧输出流将流拆分为多个流，分别进行处理。

╰+攻爆jí腚メ/ 2021年09月24日 08:12/ 0 赞/ 268 阅读