网站介绍：文章浏览阅读1.8k次。设置超时触发时间类型为ProcessingTime env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);主流程代码dataStream .keyBy(r -> r.f1)//按表名进行keyBy，避免同一张表的数据传入出现先后问题 .timeWindow(Time.of(10, TimeUnit.SECONDS))//超时时间10秒 .trigger(new CountTri_flink 写入gp
- 链接地址：https://blog.csdn.net/WuBoooo/article/details/121336158
- 链接标题：flink使用countWindow，往gp中批量写数据，并自定义超时触发器_flink 写入gp-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：3469
- 网站标签：flink 写入gp
