Users.java

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;



public class Users extends Mapper <Object, Text, Text, Text>
{
	
	static String head1;
	public static String getHead()
	{
		return head1;
	}
	
	public void map(Object key, Text value, Context context) throws IOException, InterruptedException
	{
		//Mapper for user_age table
		
		System.out.println("-----------------------------------This is users mapper process--------------------------------------------------");
		
		String record = value.toString();
		String[] parts = record.split("\t");
		String strKey = key.toString();
		
		//If header then store in static variable else write in buffer for the reducer
		if (Integer.parseInt(strKey) == 0)
		{
			head1=  parts[1];
		}
		else
		{
			context.write(new Text(parts[0]), new Text("userInfo\t" + parts[1]));
		}
	
	}
}