我有一个flink实时计算场景是需要先从MaxCompute读取一张表的存量数据,再从相应的kafka topic读取增量数据,一并进行计算处理。
看了一下需要用到hybrid source,目前最新flink社区版提供了Kafka/Hive/File 
Source,其他数据源的source是需要自己开发吗?社区有没有一个贡献source的地方?
有没有介绍如何自定义基于新版source架构的source文章或博客呢?谢谢!

Reply via email to