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

Reply via email to