Interface BatchingStateRestoreCallback

All Superinterfaces:

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

    • 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.
      records - the records to restore.
    • restore

      default void restore​(byte[] key, byte[] value)
      Specified by:
      restore in interface StateRestoreCallback