You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/04/06 21:08:50 UTC
[08/11] flink git commit: [FLINK-6256] Fix outputTag variable name in
Side Output docs
[FLINK-6256] Fix outputTag variable name in Side Output docs
This closes #3684.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6355edd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6355edd
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a6355edd
Branch: refs/heads/table-retraction
Commit: a6355edd904c2efe2ee37118132b0add5a2e5588
Parents: 153d73a
Author: zentol <ch...@apache.org>
Authored: Thu Apr 6 11:45:56 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Thu Apr 6 19:35:50 2017 +0200
----------------------------------------------------------------------
docs/dev/stream/side_output.md | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a6355edd/docs/dev/stream/side_output.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/side_output.md b/docs/dev/stream/side_output.md
index 3633b75..e4c4c19 100644
--- a/docs/dev/stream/side_output.md
+++ b/docs/dev/stream/side_output.md
@@ -41,13 +41,13 @@ side output stream:
{% highlight java %}
// this needs to be an anonymous inner class, so that we can analyze the type
-OutputTag<String> outputTag = new OutputTag<String>("string-side-output") {};
+OutputTag<String> outputTag = new OutputTag<String>("side-output") {};
{% endhighlight %}
</div>
<div data-lang="scala" markdown="1">
{% highlight scala %}
-val outputTag = OutputTag[String]("string-side-output")
+val outputTag = OutputTag[String]("side-output")
{% endhighlight %}
</div>
</div>
@@ -79,7 +79,7 @@ SingleOutputStreamOperator<Integer> mainDataStream = input
out.collect(value);
// emit data to side output
- ctx.output(sideOutputTag, "sideout-" + String.valueOf(value));
+ ctx.output(outputTag, "sideout-" + String.valueOf(value));
}
});
{% endhighlight %}
@@ -90,7 +90,7 @@ SingleOutputStreamOperator<Integer> mainDataStream = input
{% highlight scala %}
val input: DataStream[Int] = ...
-val outputTag = OutputTag[String]("string-side-output")
+val outputTag = OutputTag[String]("side-output")
val mainDataStream = input
.process(new ProcessFunction[Int, Int] {
@@ -128,7 +128,7 @@ DataStream<String> sideOutputStream = mainDataStream.getSideOutput(outputTag);
<div data-lang="scala" markdown="1">
{% highlight scala %}
-val outputTag = OutputTag[String]("string-side-output")
+val outputTag = OutputTag[String]("side-output")
val mainDataStream = ...