Hi, I'm trying to read the inputSplit over and over using following function in MapperRunner:
@Override public void run(RecordReader input, OutputCollector output, Reporter reporter) throws IOException { RecordReader copyInput = input; //First read while(input.next(key,value)); //Second read while(copyInput.next(key,value)); } It can clearly be seen that this won't work because both RecordReaders are actually the same. I'm trying to find a way for the second reader to start reading the split again from beginning ... How can I do that? Thanks, Mark