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

Class ClientComputeRecordStreamDecoder.Callback<K,V>

java.lang.Object

com.linkedin.venice.client.store.streaming.DelegatingTrackingCallback<K,V>

com.linkedin.venice.client.store.streaming.ClientComputeRecordStreamDecoder.Callback<K,V>

All Implemented Interfaces:

StreamingCallback<K,V>, TrackingStreamingCallback<K,V>

Enclosing class:

ClientComputeRecordStreamDecoder<K,V>

public abstract static class ClientComputeRecordStreamDecoder.Callback<K,V>
extends DelegatingTrackingCallback<K,V>

Constructor Summary

Constructors

Constructor	Description
Callback(TrackingStreamingCallback<K,V> inner)

Method Summary

Modifier and Type	Method	Description
abstract void	onRawRecordReceived(K key, V value)	Called for each unprocessed value record found in the stream
abstract void	onRemoteComputeStateChange(boolean enabled)

Methods inherited from class com.linkedin.venice.client.store.streaming.DelegatingTrackingCallback

getStats, onCompletion, onDeserializationCompletion, onRecordDeserialized, onRecordReceived, wrap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Callback

public Callback(TrackingStreamingCallback<K,V> inner)

Method Detail

onRawRecordReceived

public abstract void onRawRecordReceived(K key,
                                         V value)

Called for each unprocessed value record found in the stream

onRemoteComputeStateChange

public abstract void onRemoteComputeStateChange(boolean enabled)