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 2E3FD200BEA for ; Tue, 27 Dec 2016 16:05:29 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 2CEAA160B31; Tue, 27 Dec 2016 15:05:29 +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 E2654160B23 for ; Tue, 27 Dec 2016 16:05:27 +0100 (CET) Received: (qmail 10606 invoked by uid 500); 27 Dec 2016 15:05:25 -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 10596 invoked by uid 99); 27 Dec 2016 15:05:25 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 Dec 2016 15:05:25 +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 A895AC0221 for ; Tue, 27 Dec 2016 15:05:24 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.379 X-Spam-Level: ** X-Spam-Status: No, score=2.379 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id Lr7L5QAqcrMp for ; Tue, 27 Dec 2016 15:05:23 +0000 (UTC) Received: from mail-wm0-f46.google.com (mail-wm0-f46.google.com [74.125.82.46]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 3D6A05F39C for ; Tue, 27 Dec 2016 15:05:23 +0000 (UTC) Received: by mail-wm0-f46.google.com with SMTP id t79so287158448wmt.0 for ; Tue, 27 Dec 2016 07:05:23 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=pjOtWLDO4Y+/27TXSSXOnhcfLZvVqo1rKiyVmyzWi3E=; b=oS31g5dyxP7SZ+rNnQMvKdpTgJAn78j+Vg/Oupe0K1/dD8fN6NOEmGznWH8EHwZQ3J JSCbJwbpe9oG6l7ZVxjdzdrQv+GEEM6IMikjfhMJVthAJo3pjWQE4J3j40abEuzT9BEh jHO39MQ0gKKaylr04BdcomKPtVDhuDl5YsdfFgVbZRQuhWP4hT2coeplbO5In5jbOS6I S4TeVf8niUNA1lbPe6jrwRXuEf6A5GkerRXeSCIwVOqITuxBb02Xxs7TThb8PC8chtsm JKUa5CAnTBCedjq3AxpL4e4O/s7/n1Et6RRFikrxduymjIQkQufqkWqHOqSM4r0Ae+Ym VAfA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=pjOtWLDO4Y+/27TXSSXOnhcfLZvVqo1rKiyVmyzWi3E=; b=l9mEC+QOGLJ9kE/61mkrtHVHSBHVQBN2jDoyIJ0xjqunRyWEq/ck/KRcUeVfcrcEj4 AYOO8Ro5+HlFVPv8B3M8j32cMws8nWi/z6Ut0VcFeOsWtiCIr8ITABzLDdZSktJnBzsX 1rTgAZEYjEG1TXBreQsFsnlEM2jlblT/WpdIyy0BXdUMiYt0dFrpzNbrDGhN6g/cmZgv cgSHEQtTO5tFZkfs0oHJhKZaQq0SjL1nxuxUx+3GLxGA5T6lVTNapwcqIeXDpRtVNXeN NNqD+5kdSUu8l5j491PeRfWohEhenqjmMeHZXnVuLRgUxZ5FeQAIkl5dvmrM67SOE0a+ dRtw== X-Gm-Message-State: AIkVDXLWwwSI+hXBfc6yrTnRLpgx1ADFIkbh0FP1Va4aEaXIib3Qg/SFQ4CkKkdtASk1M9K/Gb7SQnzY7b7dCg== X-Received: by 10.28.143.68 with SMTP id r65mr29906649wmd.95.1482851120296; Tue, 27 Dec 2016 07:05:20 -0800 (PST) MIME-Version: 1.0 Received: by 10.194.162.129 with HTTP; Tue, 27 Dec 2016 07:04:49 -0800 (PST) In-Reply-To: References: From: Fabian Hueske Date: Tue, 27 Dec 2016 16:04:49 +0100 Message-ID: Subject: Re: Is there some way to use broadcastSet in streaming ? To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a11467d6647b9a40544a52e47 archived-at: Tue, 27 Dec 2016 15:05:29 -0000 --001a11467d6647b9a40544a52e47 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi, no, broadcast sets are not available in the DataStream API. There might be other ways to achieve similar functionality, but the optimal solution depends on the use case. If you give a few details about what you would like to do, we might be able to suggest alternatives. Best, Fabian 2016-12-27 3:38 GMT+01:00 =E5=88=98=E5=96=86 : > hi, everyone > Is there some way to use broadcastSet in streaming ? It seams that > broadcastSet is only usable in batch. > --001a11467d6647b9a40544a52e47 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

no, broadcast sets are not= available in the DataStream API.
There might be other ways t= o achieve similar functionality, but the optimal solution depends on the us= e case.
If you give a few details about what you would like t= o do, we might be able to suggest alternatives.

Best, Fabian

2016-12-27 3:38 GMT+01:00 =E5=88=98=E5=96=86 <= whitelilis@gmail.= com>:
hi, = everyone
=C2=A0=C2=A0=C2=A0 Is there some way to use broadcastSet in str= eaming ?=C2=A0 It seams that broadcastSet is only usable in batch.

--001a11467d6647b9a40544a52e47--