Flink中如何实现自定义的SourceFunction和SinkFunction？

　　1、SourceFunction： 实现SourceFunction接口，定义如何从数据源读取数据。需要实现run和cancel方法。

　　2、SinkFunction： 实现SinkFunction接口，定义如何将数据写入到目标系统。需要实现invoke方法。

　　3、注意点： 在自定义Function时，要考虑容错性、可伸缩性等因素。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群