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 9da32b6 KAFKA-9924: Add RocksDB metric num-entries-active-mem-table
(#9177)
add 85b6545 KAFKA-5636: SlidingWindows (KIP-450) (#9039)
No new revisions were added by this update.
Summary of changes:
.../kafka/streams/kstream/CogroupedKStream.java | 9 +
.../kafka/streams/kstream/KGroupedStream.java | 7 +
.../kafka/streams/kstream/SlidingWindows.java | 140 +++++
.../kstream/internals/CogroupedKStreamImpl.java | 14 +
.../internals/CogroupedStreamAggregateBuilder.java | 75 ++-
.../kstream/internals/KGroupedStreamImpl.java | 16 +
.../internals/KStreamSlidingWindowAggregate.java | 307 +++++++++
.../SessionWindowedCogroupedKStreamImpl.java | 42 +-
...va => SlidingWindowedCogroupedKStreamImpl.java} | 118 ++--
...amImpl.java => SlidingWindowedKStreamImpl.java} | 144 ++---
.../TimeWindowedCogroupedKStreamImpl.java | 52 +-
.../kstream/internals/TimeWindowedKStreamImpl.java | 45 +-
.../internals/graph/GraphGraceSearchUtil.java | 6 +
.../KStreamAggregationIntegrationTest.java | 204 ++++++
.../kafka/streams/kstream/SlidingWindowsTest.java | 82 +++
.../internals/CogroupedKStreamImplTest.java | 55 +-
.../kstream/internals/KGroupedStreamImplTest.java | 317 +++++++---
.../KStreamSlidingWindowAggregateTest.java | 692 +++++++++++++++++++++
...> SlidingWindowedCogroupedKStreamImplTest.java} | 258 +++-----
.../internals/SlidingWindowedKStreamImplTest.java | 439 +++++++++++++
.../kstream/internals/SuppressScenarioTest.java | 84 +++
21 files changed, 2566 insertions(+), 540 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedCogroupedKStreamImpl.java
=> SlidingWindowedCogroupedKStreamImpl.java} (50%)
copy
streams/src/main/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedKStreamImpl.java
=> SlidingWindowedKStreamImpl.java} (61%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
copy
streams/src/test/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedCogroupedKStreamImplTest.java
=> SlidingWindowedCogroupedKStreamImplTest.java} (53%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java
