public class AvroSerialization<T> extends Configured implements Serialization<AvroWrapper<T>>
Serialization
used by jobs configured with AvroJob
.Constructor and Description |
---|
AvroSerialization() |
Modifier and Type | Method and Description |
---|---|
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.
|
getConf, setConf
public boolean accept(Class<?> c)
accept
in interface Serialization<AvroWrapper<T>>
public Deserializer<AvroWrapper<T>> getDeserializer(Class<AvroWrapper<T>> c)
getDeserializer
in interface Serialization<AvroWrapper<T>>
public Serializer<AvroWrapper<T>> getSerializer(Class<AvroWrapper<T>> c)
getSerializer
in interface Serialization<AvroWrapper<T>>
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.