example hadoop mapper

map.java

package com.mycompany.emr;

import java.io.IOException;
import java.util.*;

import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.*;

import com.mycompany.emr.EmployeeRecord;

public class Map extends Mapper<LongWritable, EmployeeRecord, Text, IntWritable> {
  private final static IntWritable one = new IntWritable(1);
	
	public void map(LongWritable key, EmployeeRecord value, Context context) throws IOException, InterruptedException {
        context.write(new Text(value.title), one);
    }
}