This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 9407b842bd6 MINOR: fix fault handling in ControllerServer and
KafkaServer (#13331)
add 84351efd51a KAFKA-14491: [13/N] Add versioned store builder and
materializer (#13274)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/CogroupedKStreamImpl.java | 2 +-
.../kstream/internals/KGroupedStreamImpl.java | 2 +-
.../kstream/internals/KGroupedTableImpl.java | 2 +-
.../streams/kstream/internals/KTableImpl.java | 10 +-
...ializer.java => KeyValueStoreMaterializer.java} | 44 +++-
.../kstream/internals/graph/StreamToTableNode.java | 4 +-
.../kstream/internals/graph/TableSourceNode.java | 4 +-
.../internals/AbstractReadOnlyDecorator.java | 33 +++
.../internals/AbstractReadWriteDecorator.java | 33 +++
.../internals/VersionedKeyValueStoreBuilder.java | 80 +++++++
.../internals/GlobalStreamThreadTest.java | 4 +-
.../internals/KeyValueStoreMaterializerTest.java | 245 +++++++++++++++++++++
.../TimestampedKeyValueStoreMaterializerTest.java | 125 -----------
.../TimestampedKeyValueStoreBuilderTest.java | 35 ++-
.../VersionedKeyValueStoreBuilderTest.java | 146 ++++++++++++
15 files changed, 611 insertions(+), 158 deletions(-)
rename
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{TimestampedKeyValueStoreMaterializer.java
=> KeyValueStoreMaterializer.java} (57%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueStoreBuilder.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/KeyValueStoreMaterializerTest.java
delete mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/TimestampedKeyValueStoreMaterializerTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/VersionedKeyValueStoreBuilderTest.java
