Flink之Watermark实践

咱们知道实时计算中,数据时间比较敏感,有eventTime和processTime区分,通常来讲eventTime是从原始的消息中提取过来的,processTime是Flink本身提供的,Flink中一个亮点就是能够基于eventTime计算,这个功能颇有用,由于实时数据可能会通过比较长的链路,多少会有延时,而且有很大的不肯定性,对于一些须要精确体现事件变化趋势的场景中,单纯使用processTi
相关文章
相关标签/搜索