你好,关于如何实现source接口可以参考以下资料: [1] FLIP-27: Refactor Source Interface - Apache Flink - Apache Software Foundation <https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface> [2] 如何高效接入 Flink:Connecter / Catalog API 核心设计与社区进展 (qq.com) <https://mp.weixin.qq.com/s/CAxAgVDzHZ6vZ3BSvi9mlA>
Best, Shawn Huang liuchao <liuchao1...@foxmail.com> 于2024年3月28日周四 15:39写道: > 找一个实现source接口的算子,参考一下 > > > 刘超 > liuchao1...@foxmail.com > > > > > > > > > ------------------ 原始邮件 ------------------ > 发件人: > "user-zh" > < > ha.fen...@aisino.com>; > 发送时间: 2024年3月28日(星期四) 下午3:34 > 收件人: "user-zh"<user-zh@flink.apache.org>; > > 主题: Re: Re: 1.19自定义数据源 > > > > 我想问的就是如果需要实现Source接口,应该怎么写,有没有具体的例子实现一个按照一定速度生成自定义的类? > > 发件人: gongzhongqiang > 发送时间: 2024-03-28 15:05 > 收件人: user-zh > 主题: Re: 1.19自定义数据源 > 你好: > > 当前 flink 1.19 版本只是标识为过时,在未来版本会移除 SourceFunction。所以对于你的应用而言为了支持长期 flink > 版本考虑,可以将这些SourceFunction用Source重新实现。 > > ha.fen...@aisino.com <ha.fen...@aisino.com> 于2024年3月28日周四 14:18写道: > > > > > > 原来是继承SourceFunction实现一些简单的自动生成数据的方法,在1.19中已经标识为过期,好像是使用Source接口,这个和原来的SourceFunction完全不同,应该怎么样生成测试使用的自定义数据源呢? > >