需求:从MySQL中实时加载数据,要求每隔10秒钟查询flinkdb.tb_product表中的最新全量数据。继承RichSourceFunction(多功能)来自定义无并行度或继承RichParallelSourceFunction(多功能)来自定义有并行度。

实操列表

©2014-2023 百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备13018289号-12    营业执照    经营许可证:京B2-20212637