Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id CC24F200C72 for ; Thu, 6 Apr 2017 19:36:11 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id CA9D4160B9F; Thu, 6 Apr 2017 17:36:11 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 2894D160BA4 for ; Thu, 6 Apr 2017 19:36:11 +0200 (CEST) Received: (qmail 25012 invoked by uid 500); 6 Apr 2017 17:36:10 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 24801 invoked by uid 99); 6 Apr 2017 17:36:10 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Apr 2017 17:36:10 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C75B0F21A2; Thu, 6 Apr 2017 17:36:09 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: chesnay@apache.org To: commits@flink.apache.org Date: Thu, 06 Apr 2017 17:36:11 -0000 Message-Id: In-Reply-To: <5b80d823d14d4632b9481289753fb67c@git.apache.org> References: <5b80d823d14d4632b9481289753fb67c@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [3/7] flink git commit: [FLINK-6256] Fix outputTag variable name in Side Output docs archived-at: Thu, 06 Apr 2017 17:36:12 -0000 [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 Authored: Thu Apr 6 11:45:56 2017 +0200 Committer: zentol 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 outputTag = new OutputTag("string-side-output") {}; +OutputTag outputTag = new OutputTag("side-output") {}; {% endhighlight %}
{% highlight scala %} -val outputTag = OutputTag[String]("string-side-output") +val outputTag = OutputTag[String]("side-output") {% endhighlight %}
@@ -79,7 +79,7 @@ SingleOutputStreamOperator 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 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 sideOutputStream = mainDataStream.getSideOutput(outputTag);
{% highlight scala %} -val outputTag = OutputTag[String]("string-side-output") +val outputTag = OutputTag[String]("side-output") val mainDataStream = ...