You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2020/06/08 21:18:22 UTC
[kafka] branch trunk updated (6a30b4e -> ad4b12a)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 6a30b4e MINOR: equals() should check _unknownTaggedFields (#8640)
add ad4b12a KAFKA-10005: Decouple RestoreListener from RestoreCallback (#8676)
No new revisions were added by this update.
Summary of changes:
.../AbstractNotifyingBatchingRestoreCallback.java | 83 --------
.../AbstractNotifyingRestoreCallback.java | 72 -------
.../processor/BatchingStateRestoreCallback.java | 4 +
.../streams/processor/StateRestoreListener.java | 9 +-
.../processor/internals/ChangelogRegister.java | 3 +-
.../internals/CompositeRestoreListener.java | 116 -----------
.../processor/internals/ProcessorStateManager.java | 18 +-
.../RecordBatchingStateRestoreCallback.java | 5 -
.../processor/internals/StoreChangelogReader.java | 48 +----
.../AbstractRocksDBSegmentedBytesStore.java | 43 +---
...ulkLoadingStore.java => BatchWritingStore.java} | 3 +-
.../streams/state/internals/RocksDBStore.java | 60 +-----
.../state/internals/RocksDBTimestampedStore.java | 15 --
.../kafka/streams/state/internals/Segment.java | 2 +-
.../internals/CompositeRestoreListenerTest.java | 222 ---------------------
.../processor/internals/MockChangelogReader.java | 2 +-
.../internals/ProcessorStateManagerTest.java | 18 +-
.../internals/StoreChangelogReaderTest.java | 85 +-------
.../AbstractRocksDBSegmentedBytesStoreTest.java | 31 ---
.../internals/RocksDBSegmentedBytesStoreTest.java | 7 -
.../streams/state/internals/RocksDBStoreTest.java | 50 -----
.../RocksDBTimestampedSegmentedBytesStoreTest.java | 7 -
.../kafka/test/InternalMockProcessorContext.java | 20 --
.../test/MockBatchingStateRestoreListener.java | 44 ----
.../org/apache/kafka/test/MockRestoreCallback.java | 1 -
.../kafka/test/MockStateRestoreListener.java | 14 +-
26 files changed, 39 insertions(+), 943 deletions(-)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.java
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java
rename streams/src/main/java/org/apache/kafka/streams/state/internals/{BulkLoadingStore.java => BatchWritingStore.java} (91%)
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListenerTest.java
delete mode 100644 streams/src/test/java/org/apache/kafka/test/MockBatchingStateRestoreListener.java