You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/01/03 22:36:39 UTC
[4/7] beam git commit: [BEAM-1223] Fixed some javadoc.
[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 <st...@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}.
*