hadoop - Hadoop 新 API - 设置 OutputFormat

Question

我正在尝试使用以下方法将我的工作的 OutputFormat 设置为 MapFileOutputFormat：

jobConf.setOutputFormat(MapFileOutputFormat.class);

我收到此错误：mapred.output.format.class 与新的 reduce API 模式不兼容

我想我应该使用setOutputFormatClass()新 Job 类的集合，但问题是当我尝试这样做时：

job.setOutputFormatClass(MapFileOutputFormat.class);

它希望我使用这个类：org.apache.hadoop.mapreduce.lib.output.MapFileOutputFormat. 在 hadoop 1.0.X 中没有这样的类。它只存在于早期版本中（例如 0.x）

我怎么解决这个问题 ？

谢谢！

Answer 1

这个问题没有相当容易实现的解决方案。

我放弃并使用了符合我要求的序列文件。

Answer 2

您是否尝试过以下操作？

import org.apache.hadoop.mapreduce.lib.output;
...
LazyOutputFormat.setOutputFormatClass(job, MapFileOutputFormat.class);