Flink, 大数据
Posted by

flink-21 时间语义 水位线

比如1月1日买的牛奶,但是喝牛奶是1月2日,也就是买牛奶的事件时间1月1日,喝牛奶的处理时间1月2日 事件时间 数据产生的时间 处理时间 数据真正被处理的时刻 flink1.12版本开始,flink已经将事件时间作为默认的时间语义了。 ...
Flink, 大数据
Posted by

flink-19 窗口

窗口:将无限数据切割成有限的”数据块“进行处理 使用水桶接水的比喻,水桶就是窗口 在flink中,窗口其实并不是一个”框“,应该把窗口理解成一个”桶“,在flink中,窗口可以把流切割成有限大小的多个”存储桶“(bucket),每个数据都会分发到对应...