Package org.apache.storm.hdfs.avro
Class AbstractAvroSerializer
java.lang.Object
com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>
org.apache.storm.hdfs.avro.AbstractAvroSerializer
- All Implemented Interfaces:
- Serializable,- AvroSchemaRegistry
- Direct Known Subclasses:
- FixedAvroSerializer,- GenericAvroSerializer
public abstract class AbstractAvroSerializer
extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>
implements AvroSchemaRegistry
This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects
 across a Topology.  The methods in the AvroSchemaRegistry interface specify how schemas can be mapped to unique
 identifiers and vice versa.  Implementations based on pre-defining schemas or utilizing an external schema registry
 are provided.
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.avro.generic.GenericContainerread(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends org.apache.avro.generic.GenericContainer> someClass) voidwrite(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, org.apache.avro.generic.GenericContainer record) Methods inherited from class com.esotericsoftware.kryo.Serializercopy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutableMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.hdfs.avro.AvroSchemaRegistrygetFingerprint, getSchema
- 
Constructor Details- 
AbstractAvroSerializerpublic AbstractAvroSerializer()
 
- 
- 
Method Details- 
writepublic void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, org.apache.avro.generic.GenericContainer record) - Specified by:
- writein class- com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>
 
- 
readpublic org.apache.avro.generic.GenericContainer read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends org.apache.avro.generic.GenericContainer> someClass) - Specified by:
- readin class- com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>
 
 
-