Flink04--水位线
2023-02-03 08:54:30 0 举报Filnk04--水位线
作者其他创作
大纲/内容
无序数据
定点型
迟到数据处理
有序数据: 理想状态下，接受到数据是有序的，接受到数据之后不会在接受到该数据之前的数据font color=\"#ff0000\
@Override public void font color=\"#ff0000\
问题
有序数据
产生
自定义水位线生产策略class YjxxtPeriodicWatermarkStrategy implements font color=\"#ff0000\
font color=\"#ff0000\
周期型
if (i%10==0){ KafkaUtil.sendMsg(\"yjxxt\
onEvent:来一个事件调用一次onPeriodicEmit:Flink周期型调用
sideOutputLateData将符合某一规则的数据存放到一起保底方案，数据延迟严重，可以保证数据不丢失可以将数据进行收集
水位线
水位线就是数据流的一部分，随着数据传递，用于标识时间水位线是根据数据产生的
自定义处理
数据分类
生产者new Thread(()->{ //随机用户名 String uname= RandomStringUtils.randomAlphabetic(8); for (int i = 0; i < 30; i++) { KafkaUtil.sendMsg(\"yjxxt\
基础代码
0 条评论
下一页
