You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/10/18 19:34:17 UTC
[12/14] git commit: Fix the Javadoc link in DataStream class
Fix the Javadoc link in DataStream class
Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction and missing method reference in DataStream class.
Author: Henry Saputra <he...@gmail.com>
Closes #154 from hsaputra/fix_comments_streaming and squashes the following commits:
127e47a [Henry Saputra] Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction and missing method reference.
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/f396637b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/f396637b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/f396637b
Branch: refs/heads/release-0.7
Commit: f396637b46d6abcfa791874c0d9f808d42aba330
Parents: dfe392b
Author: Henry Saputra <he...@gmail.com>
Authored: Fri Oct 17 16:37:36 2014 -0700
Committer: Robert Metzger <rm...@apache.org>
Committed: Sat Oct 18 19:32:50 2014 +0200
----------------------------------------------------------------------
.../apache/flink/streaming/api/datastream/DataStream.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/f396637b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 7abde6b..000f6db 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -75,7 +75,7 @@ import org.apache.flink.streaming.util.serialization.TypeWrapper;
* <ul>
* <li>{@link DataStream#map},</li>
* <li>{@link DataStream#filter}, or</li>
- * <li>{@link DataStream#batchReduce}.</li>
+ * <li>{@link DataStream#aggregate}.</li>
* </ul>
*
* @param <OUT>
@@ -325,7 +325,7 @@ public class DataStream<OUT> {
* calls a {@link MapFunction} for each element of the DataStream. Each
* MapFunction call returns exactly one element. The user can also extend
* {@link RichMapFunction} to gain access to other features provided by the
- * {@link RichFuntion} interface.
+ * {@link org.apache.flink.api.common.functions.RichFunction} interface.
*
* @param mapper
* The MapFunction that is called for each element of the
@@ -349,7 +349,7 @@ public class DataStream<OUT> {
* transformation calls a {@link FlatMapFunction} for each element of the
* DataStream. Each FlatMapFunction call can return any number of elements
* including none. The user can also extend {@link RichFlatMapFunction} to
- * gain access to other features provided by the {@link RichFuntion}
+ * gain access to other features provided by the {@link org.apache.flink.api.common.functions.RichFunction}
* interface.
*
* @param flatMapper
@@ -373,7 +373,7 @@ public class DataStream<OUT> {
/**
* Applies a reduce transformation on the data stream. The user can also
* extend the {@link RichReduceFunction} to gain access to other features
- * provided by the {@link RichFuntion} interface.
+ * provided by the {@link org.apache.flink.api.common.functions.RichFunction} interface.
*
* @param reducer
* The {@link ReduceFunction} that will be called for every
@@ -678,7 +678,7 @@ public class DataStream<OUT> {
* DataStream and retains only those element for which the function returns
* true. Elements for which the function returns false are filtered. The
* user can also extend {@link RichFilterFunction} to gain access to other
- * features provided by the {@link RichFuntion} interface.
+ * features provided by the {@link org.apache.flink.api.common.functions.RichFunction} interface.
*
* @param filter
* The FilterFunction that is called for each element of the