Try input.clone()...

2011/6/8 Mark question <[email protected]>:
> 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
>



-- 
Stefan Wienert

http://www.wienert.cc
[email protected]

Telefon: +495251-2026838
Mobil: +49176-40170270

Reply via email to