Hi Jamal i think you use the old MR API, you should implements the Mapper interface.
Maybe you can take a look an WordCount.java example in example.org.apache.hadoop.examples. On Wed, Jan 16, 2013 at 10:03 AM, jamal sasha <[email protected]> wrote: > Hi, > The relevant code snippet posted here > http://pastebin.com/DRPXUm62 > > > On Tue, Jan 15, 2013 at 5:31 PM, jamal sasha <[email protected]>wrote: > >> My bad. Sorry I fixed it. It is BuildGraph.class >> >> >> On Tue, Jan 15, 2013 at 5:30 PM, Serge Blazhiyevskyy < >> [email protected]> wrote: >> >>> Don't you need to set this >>> >>> conf.setMapperClass(Mapper.class); >>> >>> to BuildGraph? >>> >>> >>> Serge >>> >>> >>> SERGE BLAZHIYEVSKY >>> Architect >>> (T) +1 (650) 226-0511 >>> (M) +1 (408) 772-2615 >>> [email protected]<mailto:[email protected]> >>> www.nice.com<http://www.nice.com> >>> >>> >>> On Jan 15, 2013, at 5:24 PM, jamal sasha <[email protected]<mailto: >>> [email protected]>> wrote: >>> >>> I have a mapper >>> >>> >>> public class BuildGraph{ >>> public void config(JobConf job){ <==this block doesnt seems to be >>> exexcuting at all :( >>> super.configure(job); >>> this.currentId = job.getInt("currentId",0); >>> if (this.currentId!=0){ >>> // I call a method from differnt class to build a distributed >>> cache >>> } >>> } >>> public void map(....){ >>> .... >>> } >>> } >>> >>> now the main code where this is called.. >>> >>> public void run( String params,curId){ >>> JobConf conf = new JobConf(classname.class); >>> conf.setInt("currentId",299); <--note this i am setting the value >>> here >>> conf.setMapperClass(Mapper.class); >>> //.... >>> JobClient.runJob(conf); >>> } >>> >>> But the problem is config method in the code is not executing as though >>> "currentId" returns 299 in main loop but it is not set at all in the mapper >>> class. >>> what am i doing wrong >>> >>> >> > -- Don't Grow Old, Grow Up... :-)
