开发者社区> 问答> 正文
1
0
分享

如何使用自定义partitioner ?

如何使用自定义partitioner ?

展开
收起
芯在这 2021-12-08 17:17:47 237 0
举报
1 条回答
写回答
取消 提交回答
  • 在jobconf里进行设置:jobconf.setPartitionerClass(MyPartitioner.class)

    另外需要在jobconf里明确指定reducer的个数:jobconf.setNumReduceTasks(num)

    2021-12-08 17:18:05 举报
    赞同 评论 打赏

    评论

    全部评论 (0)

    登录后可评论
问答地址:
问答排行榜
最热
最新

相关电子书

更多
# Apache Spark系列技术直播# 第五讲【 Spark RDD编程入门 】 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等