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 999fcba MINOR: refactor ControllerApis#createTopics (#10465)
add 37493d1 KAFKA-10847: Add new RocksDBTimeOrderedWindowStore that
persists (time-key)-value records (#10331)
No new revisions were added by this update.
Summary of changes:
.../ChangeLoggingTimestampedWindowBytesStore.java | 2 +-
.../internals/ChangeLoggingWindowBytesStore.java | 12 +-
...ore.java => RocksDBTimeOrderedWindowStore.java} | 124 ++++++++++++--
.../internals/RocksDbWindowBytesStoreSupplier.java | 79 ++++++---
...dowKeySchema.java => TimeOrderedKeySchema.java} | 188 +++++++++------------
...der.java => TimeOrderedWindowStoreBuilder.java} | 16 +-
.../state/internals/WindowStoreBuilder.java | 6 +-
.../AbstractRocksDBSegmentedBytesStoreTest.java | 17 +-
.../internals/AbstractWindowBytesStoreTest.java | 84 ++++++++-
.../ChangeLoggingWindowBytesStoreTest.java | 4 +-
.../RocksDBTimeOrderedWindowStoreTest.java | 70 ++++++++
.../state/internals/TimeOrderedKeySchemaTest.java | 177 +++++++++++++++++++
.../state/internals/WindowKeySchemaTest.java | 2 +-
13 files changed, 620 insertions(+), 161 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{RocksDBWindowStore.java
=> RocksDBTimeOrderedWindowStore.java} (52%)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{WindowKeySchema.java
=> TimeOrderedKeySchema.java} (54%)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{WindowStoreBuilder.java
=> TimeOrderedWindowStoreBuilder.java} (83%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeySchemaTest.java
