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

Class ClientComputeRecordStreamDecoder<K,V>

java.lang.Object

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

All Implemented Interfaces:

RecordStreamDecoder, TransportClientStreamingCallback

public class ClientComputeRecordStreamDecoder<K,V>
extends Object
implements RecordStreamDecoder

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClientComputeRecordStreamDecoder.Callback<K,V>

Constructor Summary

Constructors

Constructor

Description

ClientComputeRecordStreamDecoder(List<K> keyList, ClientComputeRecordStreamDecoder.Callback<K,V> callback, Executor deserializationExecutor, RecordDeserializer<StreamingFooterRecordV1> streamingFooterRecordDeserializer, Supplier<RecordDeserializer<V>> computeDeserializerProvider, Function<Integer,RecordDeserializer<V>> valueDeserializerProvider, BiFunction<CompressionStrategy,ByteBuffer,ByteBuffer> decompressor)

Method Summary

Modifier and Type	Method	Description
void	onCompletion(Optional<VeniceClientException> exception)	This will be invoked when the response is fully completed.
void	onDataReceived(ByteBuffer chunk)	This will be invoked when a new data chunk is available.
void	onHeaderReceived(Map<String,String> headers)	This will be invoked when headers are available.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientComputeRecordStreamDecoder

public ClientComputeRecordStreamDecoder(List<K> keyList,
 ClientComputeRecordStreamDecoder.Callback<K,V> callback,
 Executor deserializationExecutor,
 RecordDeserializer<StreamingFooterRecordV1> streamingFooterRecordDeserializer,
 Supplier<RecordDeserializer<V>> computeDeserializerProvider,
 Function<Integer,RecordDeserializer<V>> valueDeserializerProvider,
 BiFunction<CompressionStrategy,ByteBuffer,ByteBuffer> decompressor)

Method Details

onHeaderReceived

public void onHeaderReceived(Map<String,String> headers)

Description copied from interface: TransportClientStreamingCallback

This will be invoked when headers are available.

Specified by:

onHeaderReceived in interface TransportClientStreamingCallback

onDataReceived

public void onDataReceived(ByteBuffer chunk)

Description copied from interface: TransportClientStreamingCallback

This will be invoked when a new data chunk is available.

Specified by:

onDataReceived in interface TransportClientStreamingCallback

onCompletion

public void onCompletion(Optional<VeniceClientException> exception)

Description copied from interface: TransportClientStreamingCallback

This will be invoked when the response is fully completed. When any error happens, will contain the underlying exception.

Specified by:

onCompletion in interface TransportClientStreamingCallback