Hi, Please be aware that SourceFunction will be deprecated soon[1]. It is recommended to build a new source connector based on the new Source API design by FLIP-27[2]. You might take the Kafka connector as the reference implementation.
Best regards, Jing [1] https://lists.apache.org/thread/d6cwqw9b3105wcpdkwq7rr4s7x4ywqr9 [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface On Tue, Jun 14, 2022 at 6:30 AM yuxia <luoyu...@alumni.sjtu.edu.cn> wrote: > Seems you may need implement a custom connector for Scylla DB as I haven't > found a connector on hand. > Hope the doc[1][2] can help you implement your own connector. > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/ > [2] https://flink.apache.org/2021/09/07/connector-table-sql-api-part1.html > > Best regards, > Yuxia > > ------------------------------ > *发件人: *"Himanshu Sareen" <himanshusar...@outlook.com> > *收件人: *"User" <user@flink.apache.org> > *发送时间: *星期二, 2022年 6 月 14日 上午 11:29:38 > *主题: *Apache Flink - Reading data from Scylla DB > > Team, > > I'm looking for a solution to Consume/Read data from Scylla DB into Apache > Flink. > > If anyone can guide me or share pointers it will be helpful. > > Regards, > Himanshu > >
