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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Optional<ClientStats>
getStats()
void
onDeserializationCompletion(java.util.Optional<java.lang.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 Detail
-
getStats
java.util.Optional<ClientStats> getStats()
-
onRecordDeserialized
void onRecordDeserialized()
This will be invoked when any record deserialization happens.
-
onDeserializationCompletion
void onDeserializationCompletion(java.util.Optional<java.lang.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 keysduplicateEntryCount
-
-
-