@@ -0,0 +1,1328 @@
+%0D%0Apackage org.apache.hadoop.mapreduce.approx.lib.input;%0D%0Aimport java.io.IOException;%0D%0A%0D%0Aimport org.apache.hadoop.io.Text;%0D%0Aimport org.apache.hadoop.io.BytesWritable;%0D%0Aimport org.apache.hadoop.io.LongWritable;%0D%0Aimport org.apache.hadoop.mapreduce.InputSplit;%0D%0Aimport org.apache.hadoop.mapreduce.RecordReader;%0D%0Aimport org.apache.hadoop.mapreduce.TaskAttemptContext;%0D%0Aimport org.apache.hadoop.mapreduce.approx.lib.input.SampleTextInputFormat;%0D%0Aimport org.apache.hadoop.mapreduce.approx.lib.input.SampleRecordReader;%0D%0Aimport org.apache.hadoop.mapreduce.approx.lib.input.SampleFileSplit;%0D%0Aimport org.apache.hadoop.mapreduce.approx.lib.input.SampleLineRecordReader;%0D%0A%0D%0Apublic class MySampleTextInputFormat extends SampleTextInputFormat%3CLongWritable, Text%3E %7B%0D%0A%0D%0A%09@Override%0D%0A%09public RecordReader%3CLongWritable, Text%3E createRecordReader(InputSplit split, TaskAttemptContext context) throws IOException %7B%0D%0A%0D%0A%09%09SampleFileSplit sampleFileSplit = (CombineFileSplit) split;%0D%0A%09%09SampleRecordReader%3CLongWritable, Text%3E recordReader = new SampleRecordReader%3CLongWritable, Text%3E(sampleFileSplit, context, SampleLineRecordReader.class);%0D%0A%09%09try %7B%0D%0A%09%09%09recordReader.initialize(sampleFileSplit, context);%0D%0A%09%09%7D catch (InterruptedException e) %7B%0D%0A%09%09%09new RuntimeException(%22Error to initialize MySampleTextInputFormat.%22);%0D%0A%09%09%7D%0D%0A%09%09return recordReader;%0D%0A%09%7D%0D%0A%0D%0A%7D

add custom sample inputformat