我在处理中遇到错误
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的新手。
最佳答案
您正在使用更新的Hadoop版本[mapreduce]中的软件包,但其中的少数几个(TextInputFormat和TextOutputFormat)是较旧的版本[mapred软件包]。
使用map reduce的程序包总是很好的,因此您必须在下面提到更改。
import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;
引用此:https://github.com/ragnar-lothbrok/hadoop-demo
我添加了一些工作示例。