avro-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deepak Nettem <deepaknet...@gmail.com>
Subject AvroMapper map method not getting invoked
Date Thu, 29 Mar 2012 19:54:57 GMT

I am trying to run a simple Avro MapReduce Mapper only job, that reads from
an Avro source. This piece of code simply reads my avro source data and
writes it to the outpath in the exact same schema, irrespective of what is
given in the map method of the mapper. The map method is not getting
invoked at all.

Why is this happening?

public class AvroReader {

    //public static final Schema schema;
    public static final Schema IN_SCHEMA =

  public void AvroReaderRunner(String inputPath, String outputPath) throws
Exception {

   JobConf conf = new JobConf();

   Job job = new Job(conf,"AvroRecord Job..");

    AvroJob.setInputSchema(conf, IN_SCHEMA);

    //Schema stringSchema = Schema.create(Schema.Type.STRING);
    //Schema pairSchema = Pair.getPairSchema(stringSchema, stringSchema);

    AvroJob.setMapOutputSchema(conf, new Pair<Utf8,Utf8>(new Utf8(""),
0L).getSchema() );

    //AvroJob.setOutputSchema(conf, IN_SCHEMA.)
    AvroJob.setMapperClass(conf, AvroReaderMapper.class);

    FileInputFormat.addInputPath(job, new Path(inputPath));

    //FileInputFormat.addInputPath(job, new Path(inputPath));
    FileOutputFormat.setOutputPath(job, new Path(outputPath));

    //FileOutputFormat.setOutputPath(job, new Path(outputPath));

    job.setNumReduceTasks(0);                     // map-only


  public static class AvroReaderMapper extends AvroMapper<Record,
Pair<Utf8, Utf8>>{

    public void map(Record in, AvroCollector<Pair<Utf8,Utf8>> collector,
                      Reporter reporter) throws IOException {
        collector.collect(new Pair<Utf8,Utf8>('a', 'b'));




Warm Regards,
Deepak Nettem

View raw message