Package com.linkedin.venice.client.store.streaming
package com.linkedin.venice.client.store.streaming
-
ClassDescriptionAbstractRecordStreamDecoder<ENVELOPE,
K, V> Streaming callback for batch-get/compute.This class provides support to deserialize customized records even the input doesn't contain the full record.Exception when the deserialization hits partial record.This class contains two fields: 1.StreamingCallback<K,V> This class provides percentile tracking and stats emission for streaming responseThis interface exposes one more function:TrackingStreamingCallback.onDeserializationCompletion(Optional, int, int), which will be used for metric tracking.CompletableFutureimplementation to handle partial response.VeniceResponseMap<K,V> Venice customized map, which could contains either a full response or a partial response.