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 WordCountMap extends Mapper<LongWritable,Text, Text, IntWritable> {
@Override
protected void map(LongWritable key,Text value,Context context) throws IOException, InternalError, InterruptedException {
String line = value.toString();
String[] words = line.split(" ");
for(String word :words){
Text wordText = new Text(word);
IntWritable outValues = new IntWritable(1);
context.write(wordText,outValues);
}
}
}