Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
MapReduce >> mail # user >> MultipleInputs.addInputPath compile error in eclipse(indigo)


Copy link to this message
-
Re: MultipleInputs.addInputPath compile error in eclipse(indigo)
You set the wrong parameter NodeReducer.class which should be subclass of
Mapper rather than Reducer.
2013/4/2 YouPeng Yang <[EMAIL PROTECTED]>

> HI GUYS
>   I want to use the the
> org.apache.hadoop.mapreduce.lib.input.MultipleInputs;
>
>
>   However it comes a compile error in my eclipse(indigo):
>
>  public static void main(String[] args) throws IOException,
> InterruptedException, ClassNotFoundException {
> Configuration conf = new Configuration();
>  String[] otheArgs = new
> GenericOptionsParser(conf,args).getRemainingArgs();
> if(otheArgs.length != 2){
>  System.err.println("Usage:aaaa");
> System.exit(2);
> }
>  Job job = new Job(conf,"Data test2");
>  job.setReducerClass(CPUReducer.class);
>  job.setOutputKeyClass(Text.class);
> job.setOutputValueClass(Text.class);
> MultipleInputs.addInputPath(job, new Path(otheArgs[0]),
> TextInputFormat.class,CPUMapper.class);
>  MultipleInputs.addInputPath(job, new Path(otheArgs[1]),
> TextInputFormat.class,NodeReducer.class);
>     ---->The method addInputPath(Job, Path, Class<? extends InputFormat>,
> Class<? extends Mapper>) in the type MultipleInputs is not applicable for
> the arguments (Job, Path, Class<TextInputFormat>, Class<NodeReducer>
>
> FileOutputFormat.setOutputPath(job,new Path(otheArgs[2]));
> System.exit(job.waitForCompletion(true) ?  0 : 1);
>
> }
>
>    My questions:
>   1.Does the org.apache.hadoop.mapreduce.lib.input.MultipleInputs belong
>  to the new Hadoop API?
>    Why this error come out,did i miss something?
>   2.I also found  the constructor Job(Configuration, String) is deprecated
> when i declare  Job job = new Job(conf,"Data test2").
>      According to the Hadoop Defenitive Guide ,the API Job  is the new
> Hadoop API. So why the job api is deprecated .
>
>   I use the hadoop 2.0.0 with the CDH 4.1.2 .
>
>   please help me.
>
> Thanks you.
>
>
>
> Regards
>
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB