org.apache.avro.mapred

Class AvroSerialization<T>

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.avro.mapred.AvroSerialization<T>

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.serializer.Serialization<AvroWrapper<T>>

public class AvroSerialization<T>
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.io.serializer.Serialization<AvroWrapper<T>>

The Serialization used by jobs configured with AvroJob.

Constructor Summary

Constructors

Constructor and Description
AvroSerialization()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	accept(Class<?> c)
org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>>	getDeserializer(Class<AvroWrapper<T>> c) Returns the specified map output deserializer.
org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>>	getSerializer(Class<AvroWrapper<T>> c) Returns the specified output serializer.

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

AvroSerialization

public AvroSerialization()

Method Detail

accept

public boolean accept(Class<?> c)

Specified by:

accept in interface org.apache.hadoop.io.serializer.Serialization<AvroWrapper<T>>

getDeserializer

public org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>> getDeserializer(Class<AvroWrapper<T>> c)

Returns the specified map output deserializer. Defaults to the final output deserializer if no map output schema was specified.

Specified by:

getDeserializer in interface org.apache.hadoop.io.serializer.Serialization<AvroWrapper<T>>

getSerializer

public org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>> getSerializer(Class<AvroWrapper<T>> c)

Returns the specified output serializer.

Specified by:

getSerializer in interface org.apache.hadoop.io.serializer.Serialization<AvroWrapper<T>>