On Wednesday 28 September 2011 11:33 AM, Arsen Zahray wrote:
MultithreadMapper extends MultithreadedMapper<LongWritable, Text,
IntWritable, MyPage> {
ConcurrentLinkedQueue<MyScraper> scrapers = new
ConcurrentLinkedQueue<MyScraper>();
public static final int nThreads = 5;
public MyMultithreadMapper() {
for (int i = 0; i < nT
implement the map logic in a separate Mapper class and in the main
method set the following property
MultithreadedMapper.setMapperClass(job, MyMapper.class);
--
/Thanks&Regards,/
/Bh.V.S.Kamesh/