Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6DFA011EEB for ; Tue, 8 Jul 2014 07:43:58 +0000 (UTC) Received: (qmail 69216 invoked by uid 500); 8 Jul 2014 07:43:58 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 69190 invoked by uid 500); 8 Jul 2014 07:43:58 -0000 Mailing-List: contact issues-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list issues@flink.incubator.apache.org Received: (qmail 69181 invoked by uid 99); 8 Jul 2014 07:43:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 08 Jul 2014 07:43:58 +0000 X-ASF-Spam-Status: No, hits=-2000.7 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 08 Jul 2014 07:43:59 +0000 Received: (qmail 68862 invoked by uid 99); 8 Jul 2014 07:43:34 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 08 Jul 2014 07:43:34 +0000 Date: Tue, 8 Jul 2014 07:43:34 +0000 (UTC) From: "Robert Metzger (JIRA)" To: issues@flink.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-655) Rename DataSet.withBroadcastSet(DataSet, String) method MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/FLINK-655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14054614#comment-14054614 ] Robert Metzger commented on FLINK-655: -------------------------------------- I'm not sure if we still want this renaming. The discussion happened before the 0.5 release. If we change this, our users have to change their code with the 0.6 release. The package renaming from Stratosphere to Flink is not a good argument here, because thats just a replacement of the imports. > Rename DataSet.withBroadcastSet(DataSet, String) method > ------------------------------------------------------- > > Key: FLINK-655 > URL: https://issues.apache.org/jira/browse/FLINK-655 > Project: Flink > Issue Type: Improvement > Reporter: Ufuk Celebi > Labels: github-import, starter > Fix For: pre-apache > > > To broadcast a data set you have to do the following: > ```java > lorem.map(new MyMapper()).withBroadcastSet(toBroadcast, "toBroadcastName") > ``` > In the operator you call: > ```java > getRuntimeContext().getBroadcastVariable("toBroadcastName") > ``` > I propose to have both method names consistent, e.g. > - `withBroadcastVariable(DataSet, String)`, or > - `getBroadcastSet(String)`. > ---------------- Imported from GitHub ---------------- > Url: https://github.com/stratosphere/stratosphere/issues/655 > Created by: [uce|https://github.com/uce] > Labels: enhancement, java api, user satisfaction, > Created at: Wed Apr 02 16:29:08 CEST 2014 > State: open -- This message was sent by Atlassian JIRA (v6.2#6252)