org.apache.kafka.streams.processor

Interface BatchingStateRestoreCallback

All Superinterfaces:

StateRestoreCallback

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 and Description
default void	restore(byte[] key, byte[] value)
void	restoreAll(Collection<KeyValue<byte[],byte[]>> records) Called to restore a number of records.

Method Detail

restoreAll

void restoreAll(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.

restore

default void restore(byte[] key,
                     byte[] value)

Specified by:

restore in interface StateRestoreCallback