我在处理中遇到错误

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

我添加了一些工作示例。

09-05 16:47
查看更多