[BEAM-1223] Fixed some javadoc.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/488de7b1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/488de7b1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/488de7b1 Branch: refs/heads/master Commit: 488de7b1c6c973ea7f711839a436f9edc2094488 Parents: 6b68699 Author: Stas Levin <stasle...@gmail.com> Authored: Tue Jan 3 20:48:42 2017 +0200 Committer: Luke Cwik <lc...@google.com> Committed: Tue Jan 3 14:28:21 2017 -0800 ---------------------------------------------------------------------- .../apache/beam/runners/spark/aggregators/NamedAggregators.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/488de7b1/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java index 52fe994..b5aec32 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java @@ -153,9 +153,9 @@ public class NamedAggregators implements Serializable { } /** - * @param <InputT> Input data type + * @param <InputT> Input data type * @param <InterT> Intermediate data type (useful for averages) - * @param <OutputT> Output data type + * @param <OutputT> Output data type */ public static class CombineFunctionState<InputT, InterT, OutputT> implements State<InputT, InterT, OutputT> { http://git-wip-us.apache.org/repos/asf/beam/blob/488de7b1/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 3518a35..109f4e5 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 @@ -134,7 +134,7 @@ public class Min { } /** - * A {@code CombineFn} that computes the maximum of a collection of elements of type {@code T} + * A {@code CombineFn} that computes the minimum of a collection of elements of type {@code T} * using an arbitrary {@link Comparator} and an {@code identity}, * useful as an argument to {@link Combine#globally} or {@link Combine#perKey}. * @@ -146,7 +146,7 @@ public class Min { } /** - * A {@code CombineFn} that computes the maximum of a collection of elements of type {@code T} + * A {@code CombineFn} that computes the minimum of a collection of elements of type {@code T} * using an arbitrary {@link Comparator}, useful as an argument to {@link Combine#globally} or * {@link Combine#perKey}. *