package pkCustomerProfile;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;


public class CustomerInputFormat  extends FileInputFormat<Text, Text>{
    private CustomerDataReader reader = null; 
        
   
    @Override
    public RecordReader<Text, Text> createRecordReader(
            InputSplit inputSplit, TaskAttemptContext attempt) throws IOException,
            InterruptedException {
        reader = new CustomerDataReader();
        reader.initialize(inputSplit, attempt);
        return reader;
    }
}
@@ -1,8 +1,65 @@
+/******************%0AOriginal Author: Pratima Kshetry%0A*/%0A%0A
 package 
@@ -796,8 +796,9 @@
 %0A    %7D%0A%7D
+%0A

Update CustomerInputFormat.java