Class AvroSerialization<T>

  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.avro.mapred.AvroSerialization<T>
All Implemented Interfaces:
Configurable, Serialization<AvroWrapper<T>>

public class AvroSerialization<T>
extends Configured
implements Serialization<AvroWrapper<T>>

The Serialization used by jobs configured with AvroJob.

Constructor Summary
Method Summary
 boolean accept(Class<?> c)
 Deserializer<AvroWrapper<T>> getDeserializer(Class<AvroWrapper<T>> c)
          Returns the specified map output deserializer.
 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


public AvroSerialization()
Method Detail


public boolean accept(Class<?> c)
Specified by:
accept in interface Serialization<AvroWrapper<T>>


public 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 Serialization<AvroWrapper<T>>


public Serializer<AvroWrapper<T>> getSerializer(Class<AvroWrapper<T>> c)
Returns the specified output serializer.

Specified by:
getSerializer in interface Serialization<AvroWrapper<T>>

Copyright © 2011 The Apache Software Foundation. All Rights Reserved.