我們可以設置哪個版本的hadoop。在Hadoop中使用MapFileOutputFormat
job.setOutputFormatClass(MapFileOutputFormat.class);//ERROR/
基本上我有一些鍵值對,我想以文件中的排序方式寫入,然後再讀取它們。有什麼方法可以使用任何現有的hadoop功能來執行此操作。我不想爲它編寫map reduce任務。
我們可以設置哪個版本的hadoop。在Hadoop中使用MapFileOutputFormat
job.setOutputFormatClass(MapFileOutputFormat.class);//ERROR/
基本上我有一些鍵值對,我想以文件中的排序方式寫入,然後再讀取它們。有什麼方法可以使用任何現有的hadoop功能來執行此操作。我不想爲它編寫map reduce任務。
請參見:
它是可用,因爲Hadoop的0.20.0。您必須使用大於該版本的版本。
在舊的API(1.x版本):
Job job = Job.getInstance(conf);
job.setsetOutputFormat(org.apache.hadoop.mapred.MapFileOutputFormat.class);
在我們所說的新API(2盯着版):
JobConf conf = new JobConf(conf);
job.setOutputFormatClass(org.apache.hadoop.mapreduce.lib.output.MapFileOutputFormat.class);
這是行不通的.. .. job.setOutputFormatClass(MapFileOutputFormat.class)期望mapreduce包中的MapFileOutputFormat類不是來自mapred的類。其他建議? – Razvan