org.apache.avro.mapred
Class AvroMapper<IN,OUT>

java.lang.Object
  org.apache.hadoop.conf.Configured
      org.apache.avro.mapred.AvroMapper<IN,OUT>

All Implemented Interfaces:

Configurable

public class AvroMapper<IN,OUT>
extends Configured

A mapper for Avro data.

Applications subclass this class and pass their subclass to AvroJob.setMapperClass(org.apache.hadoop.mapred.JobConf, java.lang.Class), overriding map(IN, org.apache.avro.mapred.AvroCollector, org.apache.hadoop.mapred.Reporter).

Constructor Summary

AvroMapper()

Method Summary

void	map(IN datum, AvroCollector<OUT> collector, org.apache.hadoop.mapred.Reporter reporter) Called with each map input datum.

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroMapper

public AvroMapper()

Method Detail

map

public void map(IN datum,
                AvroCollector<OUT> collector,
                org.apache.hadoop.mapred.Reporter reporter)
         throws IOException

Called with each map input datum. By default, collects inputs.

Throws:

IOException