Package com.linkedin.venice.client.store.streaming
-
Interface Summary Interface Description RecordStreamDecoder StreamingCallback<K,V> TrackingStreamingCallback<K,V> This interface exposes one more function:TrackingStreamingCallback.onDeserializationCompletion(Optional, int, int), which will be used for metric tracking.VeniceResponseMap<K,V> Venice customized map, which could contains either a full response or a partial response. -
Class Summary Class Description AbstractRecordStreamDecoder<ENVELOPE,K,V> Streaming callback for batch-get/compute.ClientComputeRecordStreamDecoder<K,V> ClientComputeRecordStreamDecoder.Callback<K,V> ComputeRecordStreamDecoder<K,V> ComputeResponseRecordV1ChunkedDeserializer DelegatingTrackingCallback<K,V> MultiGetRecordStreamDecoder<K,V> MultiGetResponseRecordV1ChunkedDeserializer ReadEnvelopeChunkedDeserializer<V> This class provides support to deserialize customized records even the input doesn't contain the full record.ReadEnvelopeChunkedDeserializer.ValueContainer<V> This class contains two fields: 1.StreamingResponseTracker This class provides percentile tracking and stats emission for streaming responseVeniceResponseCompletableFuture<T> CompletableFutureimplementation to handle partial response.VeniceResponseMapImpl<K,V> -
Exception Summary Exception Description ReadEnvelopeChunkedDeserializer.NotEnoughBytesException Exception when the deserialization hits partial record.