- 链接地址：https://blog.csdn.net/qq_42082701/article/details/126248964
- 链接标题：DataStream API（基础篇） 完整使用 (第五章)-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：5143
文章浏览阅读1.2k次，点赞2次，收藏2次。大多数情况下，前面的数据源已经能够满足需要。但是凡事总有例外，如果遇到特殊情况，我们想要读取的数据源来自某个外部系统，而flink既没有预实现的方法、也没有提供连接器，又该怎么办呢？那就只好自定义实现SourceFunction了。接下来我们创建一个自定义的数据源，实现SourceFunction接口。主要重写两个关键方法：run()和cancel()。run() 方法：使用运行时上下文对象（ SourceContext ）向下游发送数据；..................
版权声明：本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除
