Package com.linkedin.venice.client.store.streaming

Class MultiGetResponseRecordV1ChunkedDeserializer

java.lang.Object

com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer<MultiGetResponseRecordV1>

com.linkedin.venice.client.store.streaming.MultiGetResponseRecordV1ChunkedDeserializer

public class MultiGetResponseRecordV1ChunkedDeserializer
extends ReadEnvelopeChunkedDeserializer<MultiGetResponseRecordV1>

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer

ReadEnvelopeChunkedDeserializer.NotEnoughBytesException, ReadEnvelopeChunkedDeserializer.ValueContainer<V>

Field Summary

Fields inherited from class com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer

NOT_ENOUGH_BYTES_EXCEPTION

Constructor Summary

Constructors

Constructor	Description
MultiGetResponseRecordV1ChunkedDeserializer()

Method Summary

Modifier and Type	Method	Description
ReadEnvelopeChunkedDeserializer.ValueContainer<MultiGetResponseRecordV1>	tryDeserializeRecord(int currentPos)	All the derived class will implement this function to provide the customized logic to deserialize a record, and when hitting partial record, it should throw ReadEnvelopeChunkedDeserializer.NotEnoughBytesException.

Methods inherited from class com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer

consume, readBytes, readBytesMeta, tryReadInt, write

Methods inherited from class java.lang.Object

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

Constructor Details

MultiGetResponseRecordV1ChunkedDeserializer

public MultiGetResponseRecordV1ChunkedDeserializer()

Method Details

tryDeserializeRecord

public ReadEnvelopeChunkedDeserializer.ValueContainer<MultiGetResponseRecordV1> tryDeserializeRecord(int currentPos)
                                                                                              throws ReadEnvelopeChunkedDeserializer.NotEnoughBytesException

Description copied from class: ReadEnvelopeChunkedDeserializer

All the derived class will implement this function to provide the customized logic to deserialize a record, and when hitting partial record, it should throw ReadEnvelopeChunkedDeserializer.NotEnoughBytesException.

Specified by:

tryDeserializeRecord in class ReadEnvelopeChunkedDeserializer<MultiGetResponseRecordV1>

Parameters:

currentPos - : current global offset to deserialize

Returns:

Throws:

ReadEnvelopeChunkedDeserializer.NotEnoughBytesException