...
Code Block | ||
---|---|---|
| ||
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(); } |
...