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 21:39:55 UTC
[2/4] 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/2f6e0011
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2f6e0011
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2f6e0011
Branch: refs/heads/release-1.4
Commit: 2f6e001172366427005975b6644194b238baff82
Parents: 78e3405
Author: okumin <ma...@okumin.com>
Authored: Sat Jan 6 22:48:02 2018 +0900
Committer: zentol <ch...@apache.org>
Committed: Mon Jan 8 20:26: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/2f6e0011/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 %}