@InterfaceAudience.Public @InterfaceStability.Evolving public abstract class AvroSerialization<T> extends Configured implements Serialization<T>
Modifier and Type | Field and Description |
---|---|
static String |
AVRO_SCHEMA_KEY |
Constructor and Description |
---|
AvroSerialization() |
Modifier and Type | Method and Description |
---|---|
Deserializer<T> |
getDeserializer(Class<T> c) |
abstract org.apache.avro.io.DatumReader<T> |
getReader(Class<T> clazz)
Create and return Avro DatumReader for the given class.
|
abstract org.apache.avro.Schema |
getSchema(T t)
Return an Avro Schema instance for the given class.
|
Serializer<T> |
getSerializer(Class<T> c) |
abstract org.apache.avro.io.DatumWriter<T> |
getWriter(Class<T> clazz)
Create and return Avro DatumWriter for the given class.
|
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept
@InterfaceAudience.Private public static final String AVRO_SCHEMA_KEY
@InterfaceAudience.Private public Deserializer<T> getDeserializer(Class<T> c)
getDeserializer
in interface Serialization<T>
Deserializer
for the given class.@InterfaceAudience.Private public Serializer<T> getSerializer(Class<T> c)
getSerializer
in interface Serialization<T>
Serializer
for the given class.@InterfaceAudience.Private public abstract org.apache.avro.Schema getSchema(T t)
@InterfaceAudience.Private public abstract org.apache.avro.io.DatumWriter<T> getWriter(Class<T> clazz)
@InterfaceAudience.Private public abstract org.apache.avro.io.DatumReader<T> getReader(Class<T> clazz)
Copyright © 2013 Apache Software Foundation. All rights reserved.