Skip to content

Commit

Permalink
[hotfix] [docs] Remove Java example code from Scala docs
Browse files Browse the repository at this point in the history
  • Loading branch information
tillrohrmann committed Mar 2, 2016
1 parent 8d67aa5 commit 80ae750
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions docs/apis/streaming/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -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>
Expand Down

0 comments on commit 80ae750

Please sign in to comment.