关于异步数据源

来源:7-16 Flink watermark概述

小小de

2019-11-02

突然想到,有些数据源是异步返回的,不确定是什么时间段返回。这种的话批处理和流处理会怎么处理尼?

写回答

1回答

Michael_PK

2019-11-02

这不是一个概念,接入的很多是日志类型的信息,比如kafka或者其他渠道过来,日志里面是有对应的产生时间的,水印是用于这场景

0
0

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程