如果你的数据源是 数据库,你可以尝试下 Flink CDC Connectors[1], 这些Connector 就是 hybrid source, 
先读历史全量数据,再读增量数据,
历史和增量阶段是无缝衔接的。

祝好,
Leonard 
[1] 
https://ververica.github.io/flink-cdc-connectors/release-2.1/content/connectors/mysql-cdc.html


> 2021年12月2日 下午2:40,张阳 <zhangyang1010...@qq.com.INVALID> 写道:
> 
> 统计的指标有大量的历史数据,怎么把历史的数据和今天的实时数据进行汇总呢。

回复