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 da8e4962911 KAFKA-20257: Refactor GlobalStateManagerImpl (#21649)
add 8f77ee6f781 KAFKA-20158: Adding SessionStore with headers adapters and
iterator facade (#21680)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/state/Stores.java | 18 ++
...Serde.java => AggregationWithHeadersSerde.java} | 16 +-
.../internals/SessionStoreBuilderWithHeaders.java | 217 +++++++++++++++++
...Facade.java => SessionStoreIteratorFacade.java} | 28 ++-
...r.java => SessionToHeadersIteratorAdapter.java} | 31 +--
.../internals/SessionToHeadersStoreAdapter.java | 203 ++++++++++++++++
.../SessionToHeadersIteratorAdapterTest.java | 110 +++++++++
.../SessionToHeadersStoreAdapterTest.java | 256 +++++++++++++++++++++
8 files changed, 849 insertions(+), 30 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{ValueTimestampHeadersSerde.java
=> AggregationWithHeadersSerde.java} (64%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderWithHeaders.java
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyValueIteratorFacade.java
=> SessionStoreIteratorFacade.java} (57%)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{TimestampedToHeadersIteratorAdapter.java
=> SessionToHeadersIteratorAdapter.java} (59%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionToHeadersStoreAdapter.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionToHeadersIteratorAdapterTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionToHeadersStoreAdapterTest.java
