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(java.util.List<K> keyList, TrackingStreamingCallback<K,V> callback, java.util.concurrent.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 Detail

ComputeRecordStreamDecoder

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

Method Detail

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>