java - 新 MapReduce API 中Reducer 中每个键的输出文件

标签 java mapreduce

我正在开发单机 Cloudera Sandbox 实例,并尝试为每个Reducer 输出生成一个输出文件。我知道可以在旧 API 中使用 MultipleTextOutputFormat 类来做到这一点,但它不再起作用了。我也不希望有下降减少阶段。

我附上一张显示我的问题的图像 enter image description here

最佳答案

使用这个MultipleOutputs .

关于java - 新 MapReduce API 中Reducer 中每个键的输出文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32781779/

相关文章:

Java链表删除对象方法

java - 如何使用java访问远程mysql数据库

java - 将 WebTestClient.BodyContentSpec 转换为 JSON 对象

java - java 中的 toString 与 toString(参数) 与 valueOf(参数)

java - 从java程序打印文本到打印机

hadoop - map task 的输入拆分来自不同的节点以及当前节点

python - hadoop-streaming: “No room for reduce task.”减少处于挂起状态的任务

hadoop - 在 hadoop reducer 中加载 native 库?

performance - 如何使用hadoop mapreduce比较两个大型数据集?

hadoop - 首次运行Hadoop MapReduce字数计数失败?