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

Class ComputeRecordStreamDecoder<K,V>

java.lang.Object

com.linkedin.venice.client.store.streaming.AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>

com.linkedin.venice.client.store.streaming.ComputeRecordStreamDecoder<K,V>

All Implemented Interfaces:

RecordStreamDecoder, TransportClientStreamingCallback

public class ComputeRecordStreamDecoder<K,V>
extends AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>

Constructor Summary

Constructors

Constructor	Description
ComputeRecordStreamDecoder(List<K> keyList, TrackingStreamingCallback<K,V> callback, Executor deserializationExecutor, RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer, RecordDeserializer<V> valueDeserializer)

Method Summary

Modifier and Type	Method	Description
protected ReadEnvelopeChunkedDeserializer<ComputeResponseRecordV1>	getEnvelopeDeserializer(int schemaId)
protected int	getKeyIndex(ComputeResponseRecordV1 envelope)
protected StreamingFooterRecordV1	getStreamingFooterRecord(ComputeResponseRecordV1 envelope)
protected V	getValueRecord(ComputeResponseRecordV1 envelope, CompressionStrategy compression)

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

onCompletion, onDataReceived, onHeaderReceived

Methods inherited from class java.lang.Object

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

Constructor Details

ComputeRecordStreamDecoder

public ComputeRecordStreamDecoder(List<K> keyList,
 TrackingStreamingCallback<K,V> callback,
 Executor deserializationExecutor,
 RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer,
 RecordDeserializer<V> valueDeserializer)

Method Details

getEnvelopeDeserializer

protected ReadEnvelopeChunkedDeserializer<ComputeResponseRecordV1> getEnvelopeDeserializer(int schemaId)

Specified by:

getEnvelopeDeserializer in class AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>

getStreamingFooterRecord

protected StreamingFooterRecordV1 getStreamingFooterRecord(ComputeResponseRecordV1 envelope)

Specified by:

getStreamingFooterRecord in class AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>

getValueRecord

protected V getValueRecord(ComputeResponseRecordV1 envelope,
 CompressionStrategy compression)

Specified by:

getValueRecord in class AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>

getKeyIndex

protected int getKeyIndex(ComputeResponseRecordV1 envelope)

Specified by:

getKeyIndex in class AbstractRecordStreamDecoder<ComputeResponseRecordV1,K,V>