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
