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

Class ComputeResponseRecordV1ChunkedDeserializer

java.lang.Object

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

com.linkedin.venice.client.store.streaming.ComputeResponseRecordV1ChunkedDeserializer

public class ComputeResponseRecordV1ChunkedDeserializer
extends ReadEnvelopeChunkedDeserializer<ComputeResponseRecordV1>

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
ComputeResponseRecordV1ChunkedDeserializer()

Method Summary

Modifier and Type	Method	Description
ReadEnvelopeChunkedDeserializer.ValueContainer<ComputeResponseRecordV1>	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 Detail

ComputeResponseRecordV1ChunkedDeserializer

public ComputeResponseRecordV1ChunkedDeserializer()

Method Detail

tryDeserializeRecord

public ReadEnvelopeChunkedDeserializer.ValueContainer<ComputeResponseRecordV1> 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<ComputeResponseRecordV1>

Parameters:

currentPos - : current global offset to deserialize

Returns:

Throws:

ReadEnvelopeChunkedDeserializer.NotEnoughBytesException