java - Java Mapreduce 中的驱动程序类错误

Question

我在处理时遇到错误

job.setInputFormatClass(TextInputFormat.class);
job.setOutputFormatClass(TextOutputFormat.class);

如何处理？任何人都可以帮助我...!

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapred.TextInputFormat;
import org.apache.hadoop.mapred.TextOutputFormat;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.mapreduce.lib.input.KeyValueTextInputFormat;

以上是导入的文件。以下代码行发生错误。

 job.setInputFormatClass(TextInputFormat.class);
 job.setOutputFormatClass(TextOutputFormat.class);

如何解决这个问题？我是 MapReduce 新手。

Answer 1

您正在使用更新的 Hadoop 版本 [mapreduce] 中的几个软件包，但其中很少有(TextInputFormat 和 TextOutputFormat)来自旧版本 [mapred package]。

使用 MapReduce 中的包总是好的，所以你必须做下面提到的更改。

import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;

引用此: https://github.com/ragnar-lothbrok/hadoop-demo

我添加了一些工作示例。