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 d83fccd65f KAFKA-13785: [5/N][emit final] cache for time ordered
window store (#12030)
add c5077c679c KAFKA-13588: consolidate `changelogFor` methods to simplify
the generation of internal topic names (#11703)
No new revisions were added by this update.
Summary of changes:
.../internals/InternalTopologyBuilder.java | 24 ++++++++-----------
.../processor/internals/ProcessorContextUtils.java | 26 +++++++++++++-------
.../state/internals/CachingWindowStore.java | 20 ++++++----------
.../InMemoryTimeOrderedKeyValueBuffer.java | 12 +++-------
.../state/internals/MeteredKeyValueStore.java | 28 ++++------------------
.../state/internals/MeteredSessionStore.java | 28 ++++------------------
.../state/internals/MeteredWindowStore.java | 24 ++++---------------
7 files changed, 49 insertions(+), 113 deletions(-)
