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 Object
implements RecordDeserializer<V>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	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(ByteBuffer byteBuffer)
V	deserialize(org.apache.avro.io.BinaryDecoder decoder)
V	deserialize(V reuseRecord, byte[] bytes)
V	deserialize(V reuseRecord, InputStream in, org.apache.avro.io.BinaryDecoder reusedDecoder)
V	deserialize(V reuse, ByteBuffer byteBuffer, org.apache.avro.io.BinaryDecoder reusedDecoder)
V	deserialize(V reuseRecord, org.apache.avro.io.BinaryDecoder decoder)
List<V>	deserializeObjects(byte[] bytes)
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 Details

AvroGenericDeserializer

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

AvroGenericDeserializer

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

Method Details

deserialize

public V deserialize(byte[] bytes)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(ByteBuffer byteBuffer)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserialize

public V deserialize(V reuse,
 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,
 InputStream in,
 org.apache.avro.io.BinaryDecoder reusedDecoder)
              throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserializeObjects

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

Specified by:

deserializeObjects in interface RecordDeserializer<V>

Throws:

VeniceSerializationException

deserializeObjects

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

Specified by:

deserializeObjects in interface RecordDeserializer<V>

Throws:

VeniceSerializationException