关于异步数据源
来源:7-16 Flink watermark概述
小小de
2019-11-02
突然想到,有些数据源是异步返回的,不确定是什么时间段返回。这种的话批处理和流处理会怎么处理尼?
写回答
1回答
-
Michael_PK
2019-11-02
这不是一个概念,接入的很多是日志类型的信息,比如kafka或者其他渠道过来,日志里面是有对应的产生时间的,水印是用于这场景
00
相似问题
关于异步数据源
来源:7-16 Flink watermark概述
小小de
2019-11-02
突然想到,有些数据源是异步返回的,不确定是什么时间段返回。这种的话批处理和流处理会怎么处理尼?
1回答
Michael_PK
2019-11-02
这不是一个概念,接入的很多是日志类型的信息,比如kafka或者其他渠道过来,日志里面是有对应的产生时间的,水印是用于这场景
相似问题