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

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