You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/06/30 17:00:30 UTC
[kafka] branch trunk updated (18dcd2c -> 0e6c8a5)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 18dcd2c MINOR: Update AlterConfigsOptions Javadoc (#8958)
add 0e6c8a5 KAFKA-10200: Fix testability of PAPI with windowed stores (#8927)
No new revisions were added by this update.
Summary of changes:
.../examples/wordcount/WordCountProcessorTest.java | 1 +
.../wordcount/WordCountTransformerTest.java | 5 +-
.../processor/internals/ProcessorContextUtils.java | 49 ++++++
.../AbstractRocksDBSegmentedBytesStore.java | 10 +-
.../streams/state/internals/AbstractSegments.java | 6 +-
.../state/internals/CachingWindowStore.java | 5 +
.../internals/ChangeLoggingWindowBytesStore.java | 5 +
.../state/internals/InMemoryWindowStore.java | 28 ++--
.../streams/state/internals/KeyValueSegments.java | 9 +-
.../kafka/streams/state/internals/Segments.java | 8 +-
.../state/internals/TimestampedSegments.java | 9 +-
.../WindowedWordCountProcessorSupplier.java | 78 +++++++++
.../wordcount/WindowedWordCountProcessorTest.java | 185 +++++++++++++++++++++
13 files changed, 363 insertions(+), 35 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
create mode 100644 streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorSupplier.java
create mode 100644 streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorTest.java