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/

Reply via email to