logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink的分流操作,简单易懂,赶紧收藏!

案例:kafka数据格式为json类型,json中的value有数组,也有json的,数组元素是json。现在提供这么一个场景,数据中的元素为同一类信息,将info 数组中的每个元素单独作为一个json串输出,同时将tags的值输出。而侧输出流的标记和提取,都离不开一个“输出标签”(OutputTag),它指定了侧输出流的id和类型。flink消费kafka,根据数据业务特点解耦写入不同的主题中,

文章图片
#flink#大数据
到底了