Package com.linkedin.venice.serialization

Class IdentityRecordDeserializer

java.lang.Object

com.linkedin.venice.serialization.IdentityRecordDeserializer

All Implemented Interfaces:

RecordDeserializer<ByteBuffer>

public class IdentityRecordDeserializer
extends Object
implements RecordDeserializer<ByteBuffer>

This class is used as an identity function to return the same bytes that were passed in the input to the output. It will reuse the inputs as much as possible.

Method Summary

Modifier and Type	Method	Description
ByteBuffer	deserialize(byte[] bytes)
ByteBuffer	deserialize(ByteBuffer byteBuffer)
ByteBuffer	deserialize(ByteBuffer reuse, byte[] bytes)
ByteBuffer	deserialize(ByteBuffer reuse, InputStream in, org.apache.avro.io.BinaryDecoder reusedDecoder)
ByteBuffer	deserialize(ByteBuffer reuse, ByteBuffer byteBuffer, org.apache.avro.io.BinaryDecoder reusedDecoder)
ByteBuffer	deserialize(ByteBuffer reuse, org.apache.avro.io.BinaryDecoder binaryDecoder)
ByteBuffer	deserialize(org.apache.avro.io.BinaryDecoder binaryDecoder)
List<ByteBuffer>	deserializeObjects(byte[] bytes)
List<ByteBuffer>	deserializeObjects(org.apache.avro.io.BinaryDecoder binaryDecoder)
static IdentityRecordDeserializer	getInstance()

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static IdentityRecordDeserializer getInstance()

deserialize

public ByteBuffer deserialize(byte[] bytes)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

public ByteBuffer deserialize(ByteBuffer byteBuffer)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

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

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

public ByteBuffer deserialize(ByteBuffer reuse,
 byte[] bytes)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

public ByteBuffer deserialize(org.apache.avro.io.BinaryDecoder binaryDecoder)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

public ByteBuffer deserialize(ByteBuffer reuse,
 org.apache.avro.io.BinaryDecoder binaryDecoder)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserialize

public ByteBuffer deserialize(ByteBuffer reuse,
 InputStream in,
 org.apache.avro.io.BinaryDecoder reusedDecoder)
                       throws VeniceSerializationException

Specified by:

deserialize in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserializeObjects

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

Specified by:

deserializeObjects in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException

deserializeObjects

public List<ByteBuffer> deserializeObjects(org.apache.avro.io.BinaryDecoder binaryDecoder)
                                    throws VeniceSerializationException

Specified by:

deserializeObjects in interface RecordDeserializer<ByteBuffer>

Throws:

VeniceSerializationException