Flink Time和Watermark的理解

Flink Time和Watermark的理解 1. Time 背景 在实际开发过程当中,咱们可能须要接入各类流数据源,好比在线业务用户点击流数据、监控系实时收集到的事件流数据、从传感器采集到的实时数据,等等,为了处理方便他们可能会写入Kafka消息中间件集群中某个/某些topic中,或者选择其它的缓冲/存储系统。这些数据源中数据元素具备固定的时间属性,是在流数据处理系统以外的其它系统生成的。好比
相关文章
相关标签/搜索