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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserialize
public V deserialize(java.nio.ByteBuffer byteBuffer) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<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 interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserialize
public V deserialize(V reuseRecord, byte[] bytes) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserialize
public V deserialize(org.apache.avro.io.BinaryDecoder decoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserialize
public V deserialize(V reuseRecord, org.apache.avro.io.BinaryDecoder decoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<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 interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserializeObjects
public java.util.List<V> deserializeObjects(byte[] bytes) throws VeniceSerializationException
- Specified by:
deserializeObjects
in interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
deserializeObjects
public java.util.List<V> deserializeObjects(org.apache.avro.io.BinaryDecoder decoder) throws VeniceSerializationException
- Specified by:
deserializeObjects
in interfaceRecordDeserializer<V>
- Throws:
VeniceSerializationException
-
-