Class IdentityRecordDeserializer
- java.lang.Object
-
- com.linkedin.venice.serialization.IdentityRecordDeserializer
-
- All Implemented Interfaces:
RecordDeserializer<java.nio.ByteBuffer>
public class IdentityRecordDeserializer extends java.lang.Object implements RecordDeserializer<java.nio.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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.nio.ByteBuffer
deserialize(byte[] bytes)
java.nio.ByteBuffer
deserialize(java.nio.ByteBuffer byteBuffer)
java.nio.ByteBuffer
deserialize(java.nio.ByteBuffer reuse, byte[] bytes)
java.nio.ByteBuffer
deserialize(java.nio.ByteBuffer reuse, java.io.InputStream in, org.apache.avro.io.BinaryDecoder reusedDecoder)
java.nio.ByteBuffer
deserialize(java.nio.ByteBuffer reuse, java.nio.ByteBuffer byteBuffer, org.apache.avro.io.BinaryDecoder reusedDecoder)
java.nio.ByteBuffer
deserialize(java.nio.ByteBuffer reuse, org.apache.avro.io.BinaryDecoder binaryDecoder)
java.nio.ByteBuffer
deserialize(org.apache.avro.io.BinaryDecoder binaryDecoder)
java.util.List<java.nio.ByteBuffer>
deserializeObjects(byte[] bytes)
java.util.List<java.nio.ByteBuffer>
deserializeObjects(org.apache.avro.io.BinaryDecoder binaryDecoder)
static IdentityRecordDeserializer
getInstance()
-
-
-
Method Detail
-
getInstance
public static IdentityRecordDeserializer getInstance()
-
deserialize
public java.nio.ByteBuffer deserialize(byte[] bytes) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(java.nio.ByteBuffer byteBuffer) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(java.nio.ByteBuffer reuse, java.nio.ByteBuffer byteBuffer, org.apache.avro.io.BinaryDecoder reusedDecoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(java.nio.ByteBuffer reuse, byte[] bytes) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(org.apache.avro.io.BinaryDecoder binaryDecoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(java.nio.ByteBuffer reuse, org.apache.avro.io.BinaryDecoder binaryDecoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserialize
public java.nio.ByteBuffer deserialize(java.nio.ByteBuffer reuse, java.io.InputStream in, org.apache.avro.io.BinaryDecoder reusedDecoder) throws VeniceSerializationException
- Specified by:
deserialize
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserializeObjects
public java.util.List<java.nio.ByteBuffer> deserializeObjects(byte[] bytes) throws VeniceSerializationException
- Specified by:
deserializeObjects
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
deserializeObjects
public java.util.List<java.nio.ByteBuffer> deserializeObjects(org.apache.avro.io.BinaryDecoder binaryDecoder) throws VeniceSerializationException
- Specified by:
deserializeObjects
in interfaceRecordDeserializer<java.nio.ByteBuffer>
- Throws:
VeniceSerializationException
-
-