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
Hadoop >> mail # user >> Error while compiling the program


Copy link to this message
-
Re: Error while compiling the program
Your delcaration of the Map class needs to include the input and
output types, e.g.:

public static class Map extends MapReduceBase implements
Mapper<LongWritable, Text, Text, LongWritable> {
...
}

-Joey

On Mon, Apr 25, 2011 at 4:38 AM, praveenesh kumar <[EMAIL PROTECTED]> wrote:
> Hi,
>
> I am running the following code (Gender.java) on my hadoop .
>
>
> import java.io.IOException;
> import java.util.*;
>
> import org.apache.hadoop.fs.Path;
> import org.apache.hadoop.conf.*;
> import org.apache.hadoop.io.*;
> import org.apache.hadoop.mapred.*;
> import org.apache.hadoop.util.*;
>
> public class Gender {
>
>    private static String genderCheck = "female";
>
>    public static class Map extends MapReduceBase implements Mapper {
>        private final static IntWritable one = new IntWritable(1);
>        private Text locText = new Text();
>
>        public void map(LongWritable key, Text value, OutputCollector
> output, Reporter reporter) throws IOException {
>            String line = value.toString();
>            String location = line.split(",")[14] + "," +
> line.split(",")[15];
>            long male = 0L;
>            long female = 0L;
>            if (line.split(",")[17].matches("\d+") &&
> line.split(",")[18].matches("\d+")) {
>                male = Long.parseLong(line.split(",")[17]);
>                female = Long.parseLong(line.split(",")[18]);
>            }
>            long diff = male - female;
>            locText.set(location);
>            if (Gender.genderCheck.toLowerCase().equals("female") && diff <
> 0) {
>                output.collect(locText, new LongWritable(diff * -1L));
>            }
>            else if (Gender.genderCheck.toLowerCase().equals("male") && diff
>> 0) {
>                output.collect(locText, new
> LongWritable(diff));
>            }
>        }
>    }
>
>    public static void main(String[] args) throws Exception {
>        JobConf conf = new JobConf(Gender.class);
>        conf.setJobName("gender");
>        conf.setOutputKeyClass(Text.class);
>        conf.setOutputValueClass(LongWritable.class);
>        conf.setMapperClass(Map.class);
>
>        if (args.length != 3) {
>            System.out.println("Usage:");
>            System.out.println("[male/female] /path/to/2kh/files
> /path/to/output");
>            System.exit(1);
>        }
>
>        if (!args[0].equalsIgnoreCase("male") &&
> !args[0].equalsIgnoreCase("female")) {
>            System.out.println("first argument must be male or female");
>            System.exit(1);
>        }
>        Gender.genderCheck = args[0];
>
>        conf.setInputFormat(TextInputFormat.class);
>        conf.setOutputFormat(TextOutputFormat.class);
>        FileInputFormat.setInputPaths(conf, new Path(args[1]));
>        FileOutputFormat.setOutputPath(conf, new Path(args[2]));
>        JobClient.runJob(conf);
>    }
>
> }
>
> I am getting the following exception while compiling this  :
>
> *Gender.java:14: Gender.Map is not abstract and does not override abstract
> method
> map(java.lang.Object,java.lang.Object,org.apache.hadoop.mapred.OutputCollector,org.apache.hadoop.mapred.Reporter)
> in org.apache.hadoop.mapred.Mapper
>    public static class Map extends MapReduceBase implements Mapper {
>                  ^
> Note: Gender.java uses or overrides a deprecated API.
> Note: Recompile with -Xlint:deprecation for details.
> Note: Gender.java uses unchecked or unsafe operations.
> Note: Recompile with -Xlint:unchecked for details.
> *
> Anyone suggest me how to debug this error ??
>

--
Joseph Echeverria
Cloudera, Inc.
443.305.9434
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