需求三: 手机号码分区

在需求一的基础上,继续完善,将不同的手机号分到不同的数据文件的当中去,需要自定 义分区来实现,这里我们自定义来模拟分区,将以下数字开头的手机号进行分开
在这里插入图片描述

自定义分区
在这里插入图片描述
作业运行添加分区设置

job.setPartitionerClass(FlowPartition.class);

修改输入输出路径, 并放入集群运行
在这里插入图片描述

Logo

技术共进,成长同行——讯飞AI开发者社区

更多推荐