You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/01/08 19:22:12 UTC

[6/9] flink git commit: [hotfix][docs] Fix DataStream iterations documentation

[hotfix][docs] Fix DataStream iterations documentation

* Fix a scala example which is using a wrong variable
* Remove partitioning descriptions
  * partitioning parameters are already removed from
  IterativeStream#closeWith/DateStream#iterate
  * https://github.com/apache/flink/pull/988
  * https://github.com/apache/flink/pull/4655

This closes #5249.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b96d100
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b96d100
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7b96d100

Branch: refs/heads/master
Commit: 7b96d10094d0a6f87a3e912e28ce8b68b310d28f
Parents: 4ac348d
Author: okumin <ma...@okumin.com>
Authored: Sat Jan 6 22:48:02 2018 +0900
Committer: zentol <ch...@apache.org>
Committed: Mon Jan 8 18:47:08 2018 +0100

----------------------------------------------------------------------
 docs/dev/datastream_api.md | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/7b96d100/docs/dev/datastream_api.md
----------------------------------------------------------------------
diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md
index 6bb755e..09580b1 100644
--- a/docs/dev/datastream_api.md
+++ b/docs/dev/datastream_api.md
@@ -375,9 +375,6 @@ iteration.closeWith(iterationBody.filter(/* one part of the stream */));
 DataStream<Integer> output = iterationBody.filter(/* some other part of the stream */);
 {% endhighlight %}
 
-By default the partitioning of the feedback stream will be automatically set to be the same as the input of the
-iteration head. To override this the user can set an optional boolean flag in the `closeWith` method.
-
 For example, here is program that continuously subtracts 1 from a series of integers until they reach zero:
 
 {% highlight java %}
@@ -424,14 +421,10 @@ are forwarded downstream using filters.
 val iteratedStream = someDataStream.iterate(
   iteration => {
     val iterationBody = iteration.map(/* this is executed many times */)
-    (tail.filter(/* one part of the stream */), tail.filter(/* some other part of the stream */))
+    (iterationBody.filter(/* one part of the stream */), iterationBody.filter(/* some other part of the stream */))
 })
 {% endhighlight %}
 
-
-By default the partitioning of the feedback stream will be automatically set to be the same as the input of the
-iteration head. To override this the user can set an optional boolean flag in the `closeWith` method.
-
 For example, here is program that continuously subtracts 1 from a series of integers until they reach zero:
 
 {% highlight scala %}