处理
时出现错误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 package]。
使用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
我已经添加了一些工作示例
与其他类相比，texttinputformat和TextOutputFormat类来自不同版本的hadoop。修复了texttinputformat和TextOutputFormat的导入。