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
-
Method Summary
Modifier and TypeMethodDescriptiontryDeserializeRecord
(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 throwReadEnvelopeChunkedDeserializer.NotEnoughBytesException
.Methods inherited from class com.linkedin.venice.client.store.streaming.ReadEnvelopeChunkedDeserializer
consume, readBytes, readBytesMeta, tryReadInt, write
-
Constructor Details
-
ComputeResponseRecordV1ChunkedDeserializer
public ComputeResponseRecordV1ChunkedDeserializer()
-
-
Method Details
-
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 throwReadEnvelopeChunkedDeserializer.NotEnoughBytesException
.- Specified by:
tryDeserializeRecord
in classReadEnvelopeChunkedDeserializer<ComputeResponseRecordV1>
- Parameters:
currentPos
- : current global offset to deserialize- Returns:
- Throws:
ReadEnvelopeChunkedDeserializer.NotEnoughBytesException
-