Package com.linkedin.venice.serializer

Class AvroGenericDeserializer<V>

java.lang.Object

com.linkedin.venice.serializer.AvroGenericDeserializer<V>

All Implemented Interfaces:

RecordDeserializer<V>

Direct Known Subclasses:

AvroSpecificDeserializer, FastAvroGenericDeserializer, MapOrderPreservingDeserializer, MapOrderPreservingFastDeserializer, VsonAvroGenericDeserializer

public class AvroGenericDeserializer<V>
extends java.lang.Object
implements RecordDeserializer<V>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AvroGenericDeserializer.IterableImpl	Deprecated.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AvroGenericDeserializer(org.apache.avro.io.DatumReader<V> datumReader)
	AvroGenericDeserializer(org.apache.avro.Schema writer, org.apache.avro.Schema reader)

Method Summary

Modifier and Type	Method	Description
V	deserialize(byte[] bytes)
V	deserialize(java.nio.ByteBuffer byteBuffer)
V	deserialize(org.apache.avro.io.BinaryDecoder decoder)
V	deserialize(V reuseRecord, byte[] bytes)
V	deserialize(V reuseRecord, java.io.InputStream in, org.apache.avro.io.BinaryDecoder reusedDecoder)
V	deserialize(V reuse, java.nio.ByteBuffer byteBuffer, org.apache.avro.io.BinaryDecoder reusedDecoder)
V	deserialize(V reuseRecord, org.apache.avro.io.BinaryDecoder decoder)
java.util.List<V>	deserializeObjects(byte[] bytes)
java.util.List<V>	deserializeObjects(org.apache.avro.io.BinaryDecoder decoder)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroGenericDeserializer

public AvroGenericDeserializer(org.apache.avro.Schema writer,
                               org.apache.avro.Schema reader)

AvroGenericDeserializer

protected AvroGenericDeserializer(org.apache.avro.io.DatumReader<V> datumReader)

Method Detail

deserialize

public V deserialize(byte[] bytes)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(java.nio.ByteBuffer byteBuffer)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(V reuse,
                     java.nio.ByteBuffer byteBuffer,
                     org.apache.avro.io.BinaryDecoder reusedDecoder)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(V reuseRecord,
                     byte[] bytes)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(org.apache.avro.io.BinaryDecoder decoder)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(V reuseRecord,
                     org.apache.avro.io.BinaryDecoder decoder)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(V reuseRecord,
                     java.io.InputStream in,
                     org.apache.avro.io.BinaryDecoder reusedDecoder)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserializeObjects

public java.util.List<V> deserializeObjects(byte[] bytes)
                                     throws VeniceSerializationException

Specified by:

deserializeObjects in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserializeObjects

public java.util.List<V> deserializeObjects(org.apache.avro.io.BinaryDecoder decoder)
                                     throws VeniceSerializationException

Specified by:

deserializeObjects in interface RecordDeserializer<V>

Throws:

VeniceSerializationException