You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2021/03/28 19:35:11 UTC
[kafka] branch trunk updated (b805882 -> d5fd491)
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 b805882 KAFKA-12562: Remove deprecated APIs in KafkaStreams and returned state classes (#10412)
add d5fd491 KAFKA-7106: remove deprecated Windows APIs (#10378)
No new revisions were added by this update.
Summary of changes:
docs/streams/upgrade-guide.html | 3 +-
.../apache/kafka/streams/kstream/JoinWindows.java | 126 ++-----------------
.../apache/kafka/streams/kstream/Materialized.java | 3 +-
.../kafka/streams/kstream/SessionWindows.java | 81 ++-----------
.../apache/kafka/streams/kstream/TimeWindows.java | 134 +++------------------
.../kafka/streams/kstream/UnlimitedWindows.java | 56 ++-------
.../org/apache/kafka/streams/kstream/Windows.java | 64 +---------
.../SessionWindowedCogroupedKStreamImpl.java | 8 +-
.../internals/SessionWindowedKStreamImpl.java | 6 +-
.../TimeWindowedCogroupedKStreamImpl.java | 45 ++-----
.../kstream/internals/TimeWindowedKStreamImpl.java | 53 +++-----
.../kstream/internals/WindowingDefaults.java | 23 ----
.../kafka/streams/kstream/JoinWindowsTest.java | 14 ---
.../kafka/streams/kstream/SessionWindowsTest.java | 20 ---
.../kafka/streams/kstream/TimeWindowsTest.java | 36 ------
.../streams/kstream/UnlimitedWindowsTest.java | 28 ++---
.../apache/kafka/streams/kstream/WindowsTest.java | 63 ----------
.../internals/KStreamWindowAggregateTest.java | 10 +-
.../internals/RepartitionOptimizingTest.java | 4 +-
19 files changed, 92 insertions(+), 685 deletions(-)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowingDefaults.java
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/WindowsTest.java