...
Code Block | ||
---|---|---|
| ||
public interface BatchingStateRestoreCallback extends StateRestoreCallback { void restoreAll(Collection<KeyValue<byte[], byte []>> records); } public interface StateRestoreListener { void onRestoreStart(TopicPartitionString topicPartitionstoreName, long startingOffset, long endOffset); void onBatchRestored(TopicPartitionString topicPartitionstoreName, long batchEndOffset, long numRestored); void onRestoreEnd(TopicPartitionString topicPartitionstoreName, long endOffset, long totalRestored); } |
...