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

Class MultiGetRecordStreamDecoder<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

RecordStreamDecoder, TransportClientStreamingCallback

public class MultiGetRecordStreamDecoder<K,V>
extends AbstractRecordStreamDecoder<MultiGetResponseRecordV1,K,V>

Constructor Summary

Constructors

Constructor	Description
MultiGetRecordStreamDecoder(List<K> keyList, TrackingStreamingCallback<K,V> callback, Executor deserializationExecutor, RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer, Function<Integer,RecordDeserializer<V>> valueDeserializerProvider, BiFunction<CompressionStrategy,ByteBuffer,ByteBuffer> decompressor)

Method Summary

Modifier and Type	Method	Description
protected ReadEnvelopeChunkedDeserializer<MultiGetResponseRecordV1>	getEnvelopeDeserializer(int schemaId)
protected int	getKeyIndex(MultiGetResponseRecordV1 envelope)
protected StreamingFooterRecordV1	getStreamingFooterRecord(MultiGetResponseRecordV1 envelope)
protected V	getValueRecord(MultiGetResponseRecordV1 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

MultiGetRecordStreamDecoder

public MultiGetRecordStreamDecoder(List<K> keyList,
 TrackingStreamingCallback<K,V> callback,
 Executor deserializationExecutor,
 RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer,
 Function<Integer,RecordDeserializer<V>> valueDeserializerProvider,
 BiFunction<CompressionStrategy,ByteBuffer,ByteBuffer> decompressor)

Method Details

getEnvelopeDeserializer

protected ReadEnvelopeChunkedDeserializer<MultiGetResponseRecordV1> getEnvelopeDeserializer(int schemaId)

Specified by:

getEnvelopeDeserializer in class AbstractRecordStreamDecoder<MultiGetResponseRecordV1,K,V>

getStreamingFooterRecord

protected StreamingFooterRecordV1 getStreamingFooterRecord(MultiGetResponseRecordV1 envelope)

Specified by:

getStreamingFooterRecord in class AbstractRecordStreamDecoder<MultiGetResponseRecordV1,K,V>

getValueRecord

protected V getValueRecord(MultiGetResponseRecordV1 envelope,
 CompressionStrategy compression)

Specified by:

getValueRecord in class AbstractRecordStreamDecoder<MultiGetResponseRecordV1,K,V>

getKeyIndex

protected int getKeyIndex(MultiGetResponseRecordV1 envelope)

Specified by:

getKeyIndex in class AbstractRecordStreamDecoder<MultiGetResponseRecordV1,K,V>