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(java.util.List<K> keyList, TrackingStreamingCallback<K,V> callback, java.util.concurrent.Executor deserializationExecutor, RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer, java.util.function.Function<java.lang.Integer,RecordDeserializer<V>> valueDeserializerProvider, java.util.function.BiFunction<CompressionStrategy,java.nio.ByteBuffer,java.nio.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 Detail

MultiGetRecordStreamDecoder

public MultiGetRecordStreamDecoder(java.util.List<K> keyList,
                                   TrackingStreamingCallback<K,V> callback,
                                   java.util.concurrent.Executor deserializationExecutor,
                                   RecordDeserializer<StreamingFooterRecordV1> streamingFooterDeserializer,
                                   java.util.function.Function<java.lang.Integer,RecordDeserializer<V>> valueDeserializerProvider,
                                   java.util.function.BiFunction<CompressionStrategy,java.nio.ByteBuffer,java.nio.ByteBuffer> decompressor)

Method Detail

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>