Flink自定义Source 抽取Mysql多张表,并行抽取可以实现吗?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink自定义Source 抽取Mysql多张表,并行抽取可以实现吗?

xiaozhennan1995@gmail.com
场景: 同时每隔30s 抽取N张Mysql的数据表,根据时间字段抽取
自定义的Source 能否通过设置Source的并行度  比如有十张表,设置并行度为3   根据并行度动态分配抽取的表 类似根据并行度和kafka的分区的关系
在一个source里,所有数据混合一起发往下游



[hidden email]