You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/06/03 11:07:00 UTC
flink git commit: [streaming] Fixing some javadoc typos
Repository: flink
Updated Branches:
refs/heads/master 90c0142ef -> bc7f6d9e5
[streaming] Fixing some javadoc typos
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc7f6d9e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bc7f6d9e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bc7f6d9e
Branch: refs/heads/master
Commit: bc7f6d9e5b6d5d4788daf6f96a0e2f56055da06a
Parents: 90c0142
Author: szape <ne...@gmail.com>
Authored: Tue Apr 14 14:15:19 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Wed Jun 3 11:00:36 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/streaming/api/datastream/DataStream.java | 2 +-
.../streaming/api/windowing/policy/ActiveTriggerPolicy.java | 4 ++--
.../streaming/api/windowing/policy/CloneableTriggerPolicy.java | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/bc7f6d9e/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 7edbec5..b9225c9 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -595,7 +595,7 @@ public class DataStream<OUT> {
*
* @param filter
* The FilterFunction that is called for each element of the
- * DataSet.
+ * DataStream.
* @return The filtered DataStream.
*/
public SingleOutputStreamOperator<OUT, ?> filter(FilterFunction<OUT> filter) {
http://git-wip-us.apache.org/repos/asf/flink/blob/bc7f6d9e/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/ActiveTriggerPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/ActiveTriggerPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/ActiveTriggerPolicy.java
index cab2bef..b645c0f 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/ActiveTriggerPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/ActiveTriggerPolicy.java
@@ -33,7 +33,7 @@ import org.apache.flink.streaming.api.windowing.helper.Timestamp;
*
* 2) An active trigger has a factory method for a runnable. This factory method
* gets called at the start up of the operator. The returned runnable will be
- * executed in its own thread and can submit fake elements at any time threw an
+ * executed in its own thread and can submit fake elements at any time through an
* {@link ActiveTriggerCallback}. This allows to have time based triggers based
* on any system internal time measure. Triggers are not called on fake
* datapoint. A fake datapoints is always considered as triggered.
@@ -62,7 +62,7 @@ public interface ActiveTriggerPolicy<DATA> extends TriggerPolicy<DATA> {
/**
* This is the factory method for a runnable. This factory method gets
* called at the start up of the operator. The returned runnable will be
- * executed in its own thread and can submit fake elements at any time threw
+ * executed in its own thread and can submit fake elements at any time through
* an {@link ActiveTriggerCallback}. This allows to have time based triggers
* based on any system internal time measure. Triggers are not called on
* fake datapoints. A fake datapoint is always considered as triggered.
http://git-wip-us.apache.org/repos/asf/flink/blob/bc7f6d9e/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableTriggerPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableTriggerPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableTriggerPolicy.java
index 5b5e20b..3f55f41 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableTriggerPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableTriggerPolicy.java
@@ -20,7 +20,7 @@ package org.apache.flink.streaming.api.windowing.policy;
/**
* When used in grouped windowing, trigger policies can provide
- * a clone method. Cloneable triggers can can be used in a distributed manner,
+ * a clone method. Cloneable triggers can be used in a distributed manner,
* which means they get cloned to provide an own instance for each group. This
* allows each group to trigger individually and only based on the elements
* belonging to the respective group.