退订
在 2024-03-28 19:56:06，"Zhanghao Chen" <zhanghao.c...@outlook.com> 写道： >如果是用的 DataStream API 的话，也可以看下新增的 DataGen Connector [1] 是否能直接满足你的测试数据生成需求。 > > >[1] >https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/datastream/datagen/ > >Best, >Zhanghao Chen >________________________________ >From: ha.fen...@aisino.com <ha.fen...@aisino.com> >Sent: Thursday, March 28, 2024 15:34 >To: user-zh <user-zh@flink.apache.org> >Subject: 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完全不同，应该怎么样生成测试使用的自定义数据源呢？ >>
