[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 <[email protected]> Authored: Sat Jan 6 22:48:02 2018 +0900 Committer: zentol <[email protected]> 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 %}
