kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (6a30b4e -> ad4b12a)
Date Mon, 08 Jun 2020 21:18:22 GMT
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


Mime
View raw message