Package 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:
Closeable
,AutoCloseable
,Configurable
,JobConfigurable
A mapper for Avro data.
Applications subclass this class and pass their subclass to
AvroJob.setMapperClass(JobConf, Class)
, overriding
map(Object, AvroCollector, Reporter)
.
-
Constructor Summary
-
Method Summary
Methods inherited from class org.apache.hadoop.conf.Configured
getConf, setConf
-
Constructor Details
-
AvroMapper
public AvroMapper()
-
-
Method Details
-
map
Called with each map input datum. By default, collects inputs.- Throws:
IOException
-
close
Subclasses can override this as desired.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
configure
Subclasses can override this as desired.- Specified by:
configure
in interfaceJobConfigurable
-