Class ClientComputeRecordStreamDecoder<K,V>
java.lang.Object
com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder<K,V>
- All Implemented Interfaces:
RecordStreamDecoder
,TransportClientStreamingCallback
-
Nested Class Summary
-
Constructor Summary
ConstructorDescriptionClientComputeRecordStreamDecoder
(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 TypeMethodDescriptionvoid
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.
-
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
Description copied from interface:TransportClientStreamingCallback
This will be invoked when headers are available.- Specified by:
onHeaderReceived
in interfaceTransportClientStreamingCallback
-
onDataReceived
Description copied from interface:TransportClientStreamingCallback
This will be invoked when a new data chunk is available.- Specified by:
onDataReceived
in interfaceTransportClientStreamingCallback
-
onCompletion
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 interfaceTransportClientStreamingCallback
-