Repository: kafka Updated Branches: refs/heads/trunk 416c3a7d9 -> dca263b4e
MINOR: fix generics in Windows.segments and Windows.until `Windows.segments(...)` and `Windows.until(...)` currently aren't returning the `Window` with its type param `W`. This causes the generic type to be lost and therefore methods using this can't infer the correct return types. Author: Damian Guy <[email protected]> Reviewers: Matthias J. Sax, Guozhang Wang Closes #1587 from dguy/windows-generics Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/dca263b4 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/dca263b4 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/dca263b4 Branch: refs/heads/trunk Commit: dca263b4e00b00983a4b9f74517b25b01492a4c6 Parents: 416c3a7 Author: Damian Guy <[email protected]> Authored: Tue Jul 5 11:38:15 2016 -0700 Committer: Guozhang Wang <[email protected]> Committed: Tue Jul 5 11:38:15 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/kafka/streams/kstream/Windows.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/dca263b4/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java index c64a80f..164e584 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java @@ -54,7 +54,7 @@ public abstract class Windows<W extends Window> { * * @return itself */ - public Windows until(long durationMs) { + public Windows<W> until(long durationMs) { this.maintainDurationMs = durationMs; return this; @@ -66,7 +66,7 @@ public abstract class Windows<W extends Window> { * * @return itself */ - protected Windows segments(int segments) { + protected Windows<W> segments(int segments) { this.segments = segments; return this;
