You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/09/14 15:28:27 UTC
[flink] 02/02: [FLINK-19083] Remove deprecated DataStream#split
from documentation
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 021712abb8cf28894fa9f1ac55c943259fbe4650
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Sun Sep 6 19:26:18 2020 +0200
[FLINK-19083] Remove deprecated DataStream#split from documentation
---
docs/dev/datastream_api.md | 4 +--
docs/dev/datastream_api.zh.md | 4 +--
docs/dev/stream/operators/index.md | 68 -----------------------------------
docs/dev/stream/operators/index.zh.md | 68 -----------------------------------
4 files changed, 4 insertions(+), 140 deletions(-)
diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md
index 5aa36c7..e58cbd2 100644
--- a/docs/dev/datastream_api.md
+++ b/docs/dev/datastream_api.md
@@ -551,7 +551,7 @@ Iterations
Iterative streaming programs implement a step function and embed it into an `IterativeStream`. As a DataStream
program may never finish, there is no maximum number of iterations. Instead, you need to specify which part
-of the stream is fed back to the iteration and which part is forwarded downstream using a `split` transformation
+of the stream is fed back to the iteration and which part is forwarded downstream using a [side output]({% link /dev/stream/side_output.md %})
or a `filter`. Here, we show an example using filters. First, we define an `IterativeStream`
{% highlight java %}
@@ -614,7 +614,7 @@ DataStream<Long> lessThanZero = minusOne.filter(new FilterFunction<Long>() {
Iterative streaming programs implement a step function and embed it into an `IterativeStream`. As a DataStream
program may never finish, there is no maximum number of iterations. Instead, you need to specify which part
-of the stream is fed back to the iteration and which part is forwarded downstream using a `split` transformation
+of the stream is fed back to the iteration and which part is forwarded downstream using a [side output]({% link /dev/stream/side_output.md %})
or a `filter`. Here, we show an example iteration where the body (the part of the computation that is repeated)
is a simple map transformation, and the elements that are fed back are distinguished by the elements that
are forwarded downstream using filters.
diff --git a/docs/dev/datastream_api.zh.md b/docs/dev/datastream_api.zh.md
index 6e24b3b..fe65162 100644
--- a/docs/dev/datastream_api.zh.md
+++ b/docs/dev/datastream_api.zh.md
@@ -551,7 +551,7 @@ Iterations
Iterative streaming programs implement a step function and embed it into an `IterativeStream`. As a DataStream
program may never finish, there is no maximum number of iterations. Instead, you need to specify which part
-of the stream is fed back to the iteration and which part is forwarded downstream using a `split` transformation
+of the stream is fed back to the iteration and which part is forwarded downstream using a [side output]({% link /dev/stream/side_output.md %})
or a `filter`. Here, we show an example using filters. First, we define an `IterativeStream`
{% highlight java %}
@@ -614,7 +614,7 @@ DataStream<Long> lessThanZero = minusOne.filter(new FilterFunction<Long>() {
Iterative streaming programs implement a step function and embed it into an `IterativeStream`. As a DataStream
program may never finish, there is no maximum number of iterations. Instead, you need to specify which part
-of the stream is fed back to the iteration and which part is forwarded downstream using a `split` transformation
+of the stream is fed back to the iteration and which part is forwarded downstream using a [side output]({% link /dev/stream/side_output.md %})
or a `filter`. Here, we show an example iteration where the body (the part of the computation that is repeated)
is a simple map transformation, and the elements that are fed back are distinguished by the elements that
are forwarded downstream using filters.
diff --git a/docs/dev/stream/operators/index.md b/docs/dev/stream/operators/index.md
index 1b9f210..765c001 100644
--- a/docs/dev/stream/operators/index.md
+++ b/docs/dev/stream/operators/index.md
@@ -346,43 +346,6 @@ connectedStreams.flatMap(new CoFlatMapFunction<Integer, String, String>() {
</td>
</tr>
<tr>
- <td><strong>Split</strong><br>DataStream → SplitStream</td>
- <td>
- <p>
- Split the stream into two or more streams according to some criterion.
-{% highlight java %}
-SplitStream<Integer> split = someDataStream.split(new OutputSelector<Integer>() {
- @Override
- public Iterable<String> select(Integer value) {
- List<String> output = new ArrayList<String>();
- if (value % 2 == 0) {
- output.add("even");
- }
- else {
- output.add("odd");
- }
- return output;
- }
-});
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
- <td><strong>Select</strong><br>SplitStream → DataStream</td>
- <td>
- <p>
- Select one or more streams from a split stream.
-{% highlight java %}
-SplitStream<Integer> split;
-DataStream<Integer> even = split.select("even");
-DataStream<Integer> odd = split.select("odd");
-DataStream<Integer> all = split.select("even","odd");
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
<td><strong>Iterate</strong><br>DataStream → IterativeStream → DataStream</td>
<td>
<p>
@@ -637,37 +600,6 @@ connectedStreams.flatMap(
</td>
</tr>
<tr>
- <td><strong>Split</strong><br>DataStream → SplitStream</td>
- <td>
- <p>
- Split the stream into two or more streams according to some criterion.
-{% highlight scala %}
-val split = someDataStream.split(
- (num: Int) =>
- (num % 2) match {
- case 0 => List("even")
- case 1 => List("odd")
- }
-)
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
- <td><strong>Select</strong><br>SplitStream → DataStream</td>
- <td>
- <p>
- Select one or more streams from a split stream.
-{% highlight scala %}
-
-val even = split select "even"
-val odd = split select "odd"
-val all = split.select("even","odd")
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
<td><strong>Iterate</strong><br>DataStream → IterativeStream → DataStream</td>
<td>
<p>
diff --git a/docs/dev/stream/operators/index.zh.md b/docs/dev/stream/operators/index.zh.md
index 1f20984..c28336c 100644
--- a/docs/dev/stream/operators/index.zh.md
+++ b/docs/dev/stream/operators/index.zh.md
@@ -346,43 +346,6 @@ connectedStreams.flatMap(new CoFlatMapFunction<Integer, String, String>() {
</td>
</tr>
<tr>
- <td><strong>Split</strong><br>DataStream → SplitStream</td>
- <td>
- <p>
- Split the stream into two or more streams according to some criterion.
-{% highlight java %}
-SplitStream<Integer> split = someDataStream.split(new OutputSelector<Integer>() {
- @Override
- public Iterable<String> select(Integer value) {
- List<String> output = new ArrayList<String>();
- if (value % 2 == 0) {
- output.add("even");
- }
- else {
- output.add("odd");
- }
- return output;
- }
-});
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
- <td><strong>Select</strong><br>SplitStream → DataStream</td>
- <td>
- <p>
- Select one or more streams from a split stream.
-{% highlight java %}
-SplitStream<Integer> split;
-DataStream<Integer> even = split.select("even");
-DataStream<Integer> odd = split.select("odd");
-DataStream<Integer> all = split.select("even","odd");
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
<td><strong>Iterate</strong><br>DataStream → IterativeStream → DataStream</td>
<td>
<p>
@@ -637,37 +600,6 @@ connectedStreams.flatMap(
</td>
</tr>
<tr>
- <td><strong>Split</strong><br>DataStream → SplitStream</td>
- <td>
- <p>
- Split the stream into two or more streams according to some criterion.
-{% highlight scala %}
-val split = someDataStream.split(
- (num: Int) =>
- (num % 2) match {
- case 0 => List("even")
- case 1 => List("odd")
- }
-)
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
- <td><strong>Select</strong><br>SplitStream → DataStream</td>
- <td>
- <p>
- Select one or more streams from a split stream.
-{% highlight scala %}
-
-val even = split select "even"
-val odd = split select "odd"
-val all = split.select("even","odd")
-{% endhighlight %}
- </p>
- </td>
- </tr>
- <tr>
<td><strong>Iterate</strong><br>DataStream → IterativeStream → DataStream</td>
<td>
<p>