hadoop-mapreduce-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kamesh <kames...@imaginea.com>
Subject Re: Type mismatch in key from map when replacing Mapper with MultithreadMapper
Date Wed, 28 Sep 2011 06:38:01 GMT
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/

Mime
View raw message