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

Interface TrackingStreamingCallback<K,V>

All Superinterfaces:

StreamingCallback<K,V>

All Known Implementing Classes:

ClientComputeRecordStreamDecoder.Callback, DelegatingTrackingCallback

public interface TrackingStreamingCallback<K,V>
extends StreamingCallback<K,V>

This interface exposes one more function: onDeserializationCompletion(Optional, int, int), which will be used for metric tracking.

Method Summary

Modifier and Type	Method	Description
Optional<ClientStats>	getStats()
void	onDeserializationCompletion(Optional<Exception> exception, int successKeyCount, int duplicateEntryCount)	This will be invoked when Venice Client deserialization is done.
void	onRecordDeserialized()	This will be invoked when any record deserialization happens.

Methods inherited from interface com.linkedin.venice.client.store.streaming.StreamingCallback

onCompletion, onRecordReceived

Method Details

getStats

Optional<ClientStats> getStats()

onRecordDeserialized

void onRecordDeserialized()

This will be invoked when any record deserialization happens.

onDeserializationCompletion

void onDeserializationCompletion(Optional<Exception> exception,
 int successKeyCount,
 int duplicateEntryCount)

This will be invoked when Venice Client deserialization is done.

Parameters:

exception -

successKeyCount - , this param indicates the total number of existing keys

duplicateEntryCount -