网站首页
编程语言
数据库
系统相关
其他分享
编程问答
KafkaSource
2024-07-17
71、Flink 的 Hybrid Source 详解
HybridSource1.概述HybridSource解决了从异构数据源顺序读取输入以生成单个输入流的问题。示例:从S3读取前几天的有界输入,然后使用Kafka的最新无界输入,当有界文件输入完成而不中断应用程序时HybridSource会从FileSource切换到KafkaSource。在HybridSource