Interface BatchingStateRestoreCallback
-
- All Superinterfaces:
StateRestoreCallback
- All Known Subinterfaces:
RecordBatchingStateRestoreCallback
- All Known Implementing Classes:
AbstractNotifyingBatchingRestoreCallback
,CompositeRestoreListener
public interface BatchingStateRestoreCallback extends StateRestoreCallback
Interface for batching restoration of aStateStore
It is expected that implementations of this class will not call theStateRestoreCallback.restore(byte[], byte[])
method.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
restoreAll(java.util.Collection<KeyValue<byte[],byte[]>> records)
Called to restore a number of records.-
Methods inherited from interface org.apache.kafka.streams.processor.StateRestoreCallback
restore
-
-
-
-
Method Detail
-
restoreAll
void restoreAll(java.util.Collection<KeyValue<byte[],byte[]>> records)
Called to restore a number of records. This method is called repeatedly until theStateStore
is fulled restored.- Parameters:
records
- the records to restore.
-
-