Flink 测流输出Demo

淡淡的烟草味﹌ 2023-06-08 03:08 8阅读 0赞

package com.storm.test_demo;
    
    import org.apache.flink.streaming.api.datastream.DataStream;
    import org.apache.flink.streaming.api.datastream.DataStreamSource;
    import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
    import org.apache.flink.util.OutputTag;
    
    /**
     * 测流输出demo
     */
    public class OutputTagDemo {
        public static void main(String[] args) {
            final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(8);
            final OutputTag<Integer> mutiOutputTag = new OutputTag<Integer>("mutiStream") {
            };
    
            DataStreamSource<Integer> integerDataStreamSource = env.fromElements(1, 2, 3, 4, 6, 67, 9, 100);
            SingleOutputStreamOperator<Integer> map = integerDataStreamSource.map(x -> x+1);
            map.print();
    
            SingleOutputStreamOperator<Integer> stream = integerDataStreamSource.process(new OutputTagDemp(mutiOutputTag));
    
            //todo 正常的流 打印
    //        stream.print();
    
            System.out.println("=======侧流输出打印");
            DataStream<Integer> sideOutputStream = stream.getSideOutput(mutiOutputTag);
    //        sideOutputStream.print();
            try {
                env.execute("aa");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

发表评论取消回复

表情：

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

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

相关阅读

相关【flink】 flink入门教程demo 初识flink

文章目录通俗解释什么是flink及其应用场景 flink处理流程及核心API flink代码快速入门 flink重要概念 > 什么是flink

阳光穿透心脏的1/2处/ 2024年03月26日 16:40/ 0 赞/ 97 阅读

相关 Java输入输出流demo介绍

注：此demo用在从数据库中获取图片后进行数据转化返给前端的项目中。 //创建输入流，new出来的输入流要根据需求来选择，当下是用字节数组来传输数据，故用了 B

左手的ㄟ右手/ 2024年03月23日 22:14/ 0 赞/ 92 阅读

相关 Flink侧输出流及案例

flink可以起到分流的其实有很多种方式，比如 keyBy filter 不过，这些流的数据类型也都相同不如process function的side outputs

ゝ一纸荒年。/ 2023年10月06日 23:14/ 0 赞/ 13 阅读

相关 Flink 测流输出Demo

package com.storm.test_demo; import org.apache.flink.streaming.api.datastre

淡淡的烟草味﹌/ 2023年06月08日 03:08/ 0 赞/ 9 阅读

相关 Flink---侧输出流（SideOutput）

要求：将小于32℃输入到侧输入流，大于32℃输入到主流 import org.apache.flink.api.scala._ import org.apac

ゞ浴缸里的玫瑰/ 2023年02月22日 13:35/ 0 赞/ 9 阅读

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

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

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

相关 4.1.15 Flink-流处理框架-Flink流处理API之sink输出操作

目录 1.写在前面 2.输出到Kafka（source/sink） 3.输出到Redis（sink） 4.输出到Elasticsearch（sink） 5.JDBC

冷不防/ 2022年11月04日 11:27/ 0 赞/ 291 阅读

相关 Flink——Side Output侧输出流

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

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

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

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

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

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

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

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