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