自定义fink source

本文主要是介绍自定义fink source，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

实现思路：

（1）继承RichSourceFunction

（2）在open方法里重写初始化内容

（3）在run方法里实现具体的数据生成逻辑，例如从数据库中读取、或者程序自动生成，使用context.collect(str)，来将数据输出

（4）可以调用cancle来取消数据生成

参考资料：

Flink自定义source、自定义sink-阿里云开发者社区

这篇关于自定义fink source的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---