flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [3/7] flink git commit: [FLINK-6256] Fix outputTag variable name in Side Output docs
Date Thu, 06 Apr 2017 17:36:11 GMT
[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/master
Commit: a6355edd904c2efe2ee37118132b0add5a2e5588
Parents: 153d73a
Author: zentol <chesnay@apache.org>
Authored: Thu Apr 6 11:45:56 2017 +0200
Committer: zentol <chesnay@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 = ...
 


Mime
View raw message