Flink之对时间的处理

window+trigger+watermark处理全局乱序数据，指定窗口上的allowedLateness可以处理特定窗口操作的局部事件时间乱序数据 1、流处理系统中的微批 Flink内部也使用了某种形式的微批处理技术，在shuffle阶段将含有多个事件的缓冲容器通过网络发送，而不是发送单个事件
posted @ 2020-07-16 10:15  码以致用  阅读(4009)  评论(0)  编辑  收藏  举报