Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5D4D51862F for ; Tue, 12 Jan 2016 10:49:57 +0000 (UTC) Received: (qmail 23992 invoked by uid 500); 12 Jan 2016 10:49:57 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 23905 invoked by uid 500); 12 Jan 2016 10:49:57 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 23895 invoked by uid 99); 12 Jan 2016 10:49:57 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 Jan 2016 10:49:57 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id AD758C0DCB for ; Tue, 12 Jan 2016 10:49:56 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.98 X-Spam-Level: ** X-Spam-Status: No, score=2.98 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=radicalbit-io.20150623.gappssmtp.com Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id GdGHf0vmkdnr for ; Tue, 12 Jan 2016 10:49:55 +0000 (UTC) Received: from mail-vk0-f52.google.com (mail-vk0-f52.google.com [209.85.213.52]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 9BE32231DC for ; Tue, 12 Jan 2016 10:49:55 +0000 (UTC) Received: by mail-vk0-f52.google.com with SMTP id a123so209949568vkh.1 for ; Tue, 12 Jan 2016 02:49:55 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=radicalbit-io.20150623.gappssmtp.com; s=20150623; h=mime-version:date:message-id:subject:from:to:content-type; bh=ghQkl+tUwjpolw/GM1j+BeF9krDir8P5OcPbGk1agKo=; b=xbgLDphEOLL9Gi8iiPp0U/F0SYgjNS6p5rlWjknqqqtuCxMDa73XARHnSXBKZm6aku AKkoJXNRr7/pt5TmO2Y4/MjYAV7ZbETsh02wzFnKaBb16MYxKe6kmefX0SO4LOOCQwmD /IyUW9q7hxl443ypXbYUi04W4Ae1P2JNsPaakpNxYKtcINJxhHKNUL8YQveHGNmYMww6 nSaKg0V8+b/GVWDfMSSxitEoK41fmedvSodVHgsH/eJY3GimQUPpmyoebHSmH6bSwKRQ cgXoRntjuX52UTrRxxG1vIUPtXpQsNBvNm4T9jrspdHvZo6riANM5S7Ffq9noDbDxEQp LNYw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:date:message-id:subject:from:to :content-type; bh=ghQkl+tUwjpolw/GM1j+BeF9krDir8P5OcPbGk1agKo=; b=N1/XeGpu2p5J9Y2/goa/+wlxQh4IVeXGSZyWN2xVeWhoNpZlpQfUms2avkGaqatSUS 8dfkwG0KaCV5sNrxT2GUZNzFSWhELZs+/L8i/El2k2M1zSSFbNEuniINVtdczMH396Ky 1CJXvQ3hnakKun03ApQzFeVT4EvBxvb8AebxB4q7d/gYKS8DnQVBkweOnfdRoAL+g8A2 xaHZVLcLWy3X9zOOPIprglZ3DzJG7Vs1LSYt9WbjwH1wS1lrvPJJjKvMWZwd0MF+/WPv XmFnqsevuxWlhN0ewSvRqN3MiaTS48VCOvplwaJrblIMYidHiHkfhPBVIRz7yEaH+Edy 5QAg== X-Gm-Message-State: ALoCoQnQ3SV8n6hPSb/XOH4z1ARu2Twl8+ANttzzpsZAyGxSmQ6I2GWWSNMvLwfUU1zYjzhRWsTs8YmVWn4nZOsRYEMjh1G7DA== MIME-Version: 1.0 X-Received: by 10.31.52.147 with SMTP id b141mr84329221vka.82.1452595794534; Tue, 12 Jan 2016 02:49:54 -0800 (PST) Received: by 10.31.173.4 with HTTP; Tue, 12 Jan 2016 02:49:54 -0800 (PST) Date: Tue, 12 Jan 2016 11:49:54 +0100 Message-ID: Subject: Broadcast variable: error in the wiki? From: Stefano Baghino To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1143f8465669bf052920d0ae --001a1143f8465669bf052920d0ae Content-Type: text/plain; charset=UTF-8 Hi all, I'm starting to get familiar with Flink. With the help of a colleague I've noticed what I think may be an error in the documentation about broadcast variables ( https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables ). The documentation states that a broadcast variable "takes a Flink DataSet and makes it available to all function instances". Then it goes on with an example of an anonymous MapFunction invoking the getRuntimeContext method. However, if I got it right, you need to extend a RichMapFunction in order to have access to the runtime context. We've checked the code as well and it looks like getRuntimeContext is only available to classes extending AbstractRichFunction. I'd like to edit the wiki page myself but unfortunately I don't seem to have writing privileges. Is there a way for me to contribute to the documentation? Thank you in advance. -- BR, Stefano Baghino Software Engineer @ Radicalbit --001a1143f8465669bf052920d0ae Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi all, I'm starting to get familiar with Flink. = With the help of a colleague I've noticed what I think may be an error = in the documentation about broadcast variables (https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.= +Broadcast+Variables).

The documentation state= s that a broadcast variable "takes a Flink DataSet and makes it availa= ble to all function instances". Then it goes on with an example of an = anonymous MapFunction invoking the getRuntimeContext method. However, if I = got it right, you need to extend a RichMapFunction in order to have access = to the runtime context. We've checked the code as well and it looks lik= e getRuntimeContext is only available to classes extending AbstractRichFunc= tion.

I'd like to edit the wiki page myself bu= t unfortunately I don't seem to have writing privileges. Is there a way= for me to contribute to the documentation? Thank you in advance.

--
BR,
Stefano Baghino

Software Engineer @ Radical= bit
--001a1143f8465669bf052920d0ae--