flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [hotfix] [docs] Remove Java example code from Scala docs
Date Wed, 02 Mar 2016 10:50:44 GMT
Repository: flink
Updated Branches:
  refs/heads/master 8d67aa55f -> 80ae75053


[hotfix] [docs] Remove Java example code from Scala docs


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

Branch: refs/heads/master
Commit: 80ae75053d4a3fc71f428b87a8f0a9349da6047b
Parents: 8d67aa5
Author: Till Rohrmann <trohrmann@apache.org>
Authored: Wed Mar 2 11:50:04 2016 +0100
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Wed Mar 2 11:50:04 2016 +0100

----------------------------------------------------------------------
 docs/apis/streaming/index.md | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/80ae7505/docs/apis/streaming/index.md
----------------------------------------------------------------------
diff --git a/docs/apis/streaming/index.md b/docs/apis/streaming/index.md
index 3741a46..5363d72 100644
--- a/docs/apis/streaming/index.md
+++ b/docs/apis/streaming/index.md
@@ -847,16 +847,12 @@ val all = split.select("even","odd")
 		to the feedback channel, and the rest of the elements are forwarded downstream.
 		See <a href="#iterations">iterations</a> for a complete description.
                 {% highlight java %}
-initialStream. iterate {
+initialStream.iterate {
   iteration => {
     val iterationBody = iteration.map {/*do something*/}
     (iterationBody.filter(_ > 0), iterationBody.filter(_ <= 0))
   }
 }
-IterativeStream<Long> iteration = initialStream.iterate();
-DataStream<Long> iterationBody = iteration.map (/*do something*/);
-DataStream<Long> feedback = iterationBody.filter ( _ > 0);
-iteration.closeWith(feedback);
                 {% endhighlight %}
             </p>
           </td>


Mime
View raw message