org.apache.gora.cassandra.serializers

Class AvroSerializerUtil

java.lang.Object

org.apache.gora.cassandra.serializers.AvroSerializerUtil

public class AvroSerializerUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<org.apache.avro.io.BinaryDecoder>	decoders
static ThreadLocal<org.apache.avro.io.BinaryEncoder>	encoders
static ConcurrentHashMap<String,org.apache.avro.specific.SpecificDatumReader<?>>	readerMap
static ConcurrentHashMap<String,org.apache.avro.specific.SpecificDatumWriter<?>>	writerMap Create a ConcurrentHashMap for the datum readers and writers.

Constructor Summary

Constructors

Constructor and Description
AvroSerializerUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static Object	deserializer(Object value, org.apache.avro.Schema schema)
static <T> byte[]	serializer(T value, org.apache.avro.Schema schema)

Methods inherited from class java.lang.Object

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

Field Detail

encoders

public static final ThreadLocal<org.apache.avro.io.BinaryEncoder> encoders

decoders

public static final ThreadLocal<org.apache.avro.io.BinaryDecoder> decoders

writerMap

public static final ConcurrentHashMap<String,org.apache.avro.specific.SpecificDatumWriter<?>> writerMap

Create a ConcurrentHashMap for the datum readers and writers. This is necessary because they are not thread safe, at least not before Avro 1.4.0 (See AVRO-650). When they are thread safe, it is possible to maintain a single reader and writer pair for every schema, instead of one for every thread.

See Also:

AVRO-650

readerMap

public static final ConcurrentHashMap<String,org.apache.avro.specific.SpecificDatumReader<?>> readerMap

Constructor Detail

AvroSerializerUtil

public AvroSerializerUtil()

Method Detail

serializer

public static <T> byte[] serializer(T value,
                    org.apache.avro.Schema schema)
                         throws IOException

Throws:

IOException

deserializer

public static Object deserializer(Object value,
                  org.apache.avro.Schema schema)
                           throws IOException

Throws:

IOException