[BEAM-1223] Resolved some type-safety related warnings.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6b68699c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6b68699c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6b68699c Branch: refs/heads/master Commit: 6b68699cd75e8b17bc84cf58053fe1f7583e447f Parents: 78a360e Author: Stas Levin <[email protected]> Authored: Mon Jan 2 18:29:21 2017 +0200 Committer: Luke Cwik <[email protected]> Committed: Tue Jan 3 14:28:19 2017 -0800 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/transforms/Max.java | 4 ++-- .../core/src/main/java/org/apache/beam/sdk/transforms/Min.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/6b68699c/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java index 696bed9..91851bc 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java @@ -195,7 +195,7 @@ public class Max { */ public static <T, ComparatorT extends Comparator<? super T> & Serializable> Combine.Globally<T, T> globally(ComparatorT comparator) { - return Combine.<T, T>globally(Max.of(comparator)); + return Combine.<T, T>globally(Max.<T, ComparatorT>of(comparator)); } /** @@ -207,7 +207,7 @@ public class Max { */ public static <K, T, ComparatorT extends Comparator<? super T> & Serializable> Combine.PerKey<K, T, T> perKey(ComparatorT comparator) { - return Combine.<K, T, T>perKey(Max.of(comparator)); + return Combine.<K, T, T>perKey(Max.<T, ComparatorT>of(comparator)); } ///////////////////////////////////////////////////////////////////////////// http://git-wip-us.apache.org/repos/asf/beam/blob/6b68699c/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java index b208929..3518a35 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java @@ -195,7 +195,7 @@ public class Min { */ public static <T, ComparatorT extends Comparator<? super T> & Serializable> Combine.Globally<T, T> globally(ComparatorT comparator) { - return Combine.<T, T>globally(Min.of(comparator)); + return Combine.<T, T>globally(Min.<T, ComparatorT>of(comparator)); } /** @@ -207,7 +207,7 @@ public class Min { */ public static <K, T, ComparatorT extends Comparator<? super T> & Serializable> Combine.PerKey<K, T, T> perKey(ComparatorT comparator) { - return Combine.<K, T, T>perKey(Min.of(comparator)); + return Combine.<K, T, T>perKey(Min.<T, ComparatorT>of(comparator)); } /////////////////////////////////////////////////////////////////////////////
