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