org.apache.storm.hdfs.avro

Class FixedAvroSerializer

java.lang.Object

com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>

org.apache.storm.hdfs.avro.AbstractAvroSerializer

org.apache.storm.hdfs.avro.FixedAvroSerializer

All Implemented Interfaces:

Serializable, AvroSchemaRegistry

public class FixedAvroSerializer
extends AbstractAvroSerializer

A class to help (de)serialize a pre-defined set of Avro schemas. Schemas should be listed, one per line, in a file called "FixedAvroSerializer.config", which must be part of the Storm topology jar file. Any schemas intended to be used with this class **MUST** be defined in that file.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FixedAvroSerializer()

Method Summary

Modifier and Type	Method and Description
String	getFingerprint(org.apache.avro.Schema schema)
org.apache.avro.Schema	getSchema(String fingerPrint)

Methods inherited from class org.apache.storm.hdfs.avro.AbstractAvroSerializer

read, write

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedAvroSerializer

public FixedAvroSerializer()
                    throws IOException,
                           NoSuchAlgorithmException

Throws:

IOException

NoSuchAlgorithmException

Method Detail

getFingerprint

public String getFingerprint(org.apache.avro.Schema schema)

getSchema

public org.apache.avro.Schema getSchema(String fingerPrint)