java MapReduce - Map类
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java MapReduce - Map类相关的知识,希望对你有一定的参考价值。
package com.company;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import java.io.IOException;
public class Map extends Mapper<LongWritable,Text,Text,IntWritable> {
@Override
public void map(LongWritable key, Text value, Context context)
throws IOException, InterruptedException {
String[] row = value.toString().split("\t");
context.write(new Text(row[2]),new IntWritable(1));
}
}
以上是关于java MapReduce - Map类的主要内容,如果未能解决你的问题,请参考以下文章