[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 <ches...@apache.org> Authored: Thu Apr 6 11:45:56 2017 +0200 Committer: zentol <ches...@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 = ...