Page History

public interface BatchingStateRestoreCallback extends StateRestoreCallback {

   void restoreAll(Collection<KeyValue<byte[], byte []>> records);

   void beginRestore(StateRestoreContext restoreContext);

   void endRestore();

}
 
 
public interface StateRestoreContext {

  void updateOffsetRestoredupdateLastOffsetRestored(long offset);
 
  void updateNumberRestored(int restoreCount);

  long offsetRestoredlastOffsetRestored();
  
  int numberRestored();

}