Page History

public interface BatchingStateRestoreCallback extends StateRestoreCallback {

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

   void beginRestore(StateRestoreContext restoreContext);

   void endRestore();

}
 
 
public interface StateRestoreContext {

  void setOffsetRestoredupdateOffsetRestored(long offset);
 
  void setNumberRestoredupdateNumberRestored(int restoreCount);

  long offsetRestored();
  
  int numberRestored();

}