Package org.apache.kafka.streams.processor

Interface BatchingStateRestoreCallback

All Superinterfaces:

StateRestoreCallback

All Known Implementing Classes:

AbstractNotifyingBatchingRestoreCallback

public interface BatchingStateRestoreCallback
extends StateRestoreCallback

Interface for batching restoration of a StateStore It is expected that implementations of this class will not call the StateRestoreCallback.restore(byte[], byte[]) method.

Method Summary

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 the StateStore is fulled restored.

Parameters:

records - the records to restore.