分配时间戳和生成水位线
发布于: 2020 年 10 月 14 日
事件时间处理Flink提供2个信息
每个事件都需要关联一个时间戳，该时间戳表示事件真实发生的时间
事件时间数据流还需要携带水位线
水位线
水位线用于告知算子不必再等那些时间戳小于或等于水位线的事件
最佳做法是尽可能靠近数据源的地方，甚至是SourceFunction内部，分配时间戳并生成水位线
时间戳分配器
时间戳分配器会作用在数据流的元素上，生成一条带有时间戳和水位线的新的数据流，时间戳分配器不会改变DataStream的数据类型
奇迹的出现往往就在再坚持一下的时候！ 2018.04.02 加入
还未添加个人简介
评论