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 637BF200D3B for ; Fri, 10 Nov 2017 23:56:48 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 61F9F160BEE; Fri, 10 Nov 2017 22:56:48 +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 52A7C160BE0 for ; Fri, 10 Nov 2017 23:56:47 +0100 (CET) Received: (qmail 39341 invoked by uid 500); 10 Nov 2017 22:56:45 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 39331 invoked by uid 99); 10 Nov 2017 22:56:45 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Nov 2017 22:56:45 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 28F7DD95CE for ; Fri, 10 Nov 2017 22:56:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.021 X-Spam-Level: X-Spam-Status: No, score=-3.021 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id Cf7CqjNfjY5L for ; Fri, 10 Nov 2017 22:56:44 +0000 (UTC) Received: from stleegwp1.mastercard.com (mail.myprepaidsolution.com [216.119.215.10]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 6110660DE7 for ; Fri, 10 Nov 2017 22:56:43 +0000 (UTC) Received: from webmail.mastercard.com (stl3vont01.corp.mastercard.org [172.19.128.146]) by stleegwp1c.corp.mastercard.int (8.16.0.21/8.16.0.21) with ESMTPS id vAAMugqB005280 (version=TLSv1.2 cipher=AES256-SHA bits=256 verify=NOT) for ; Fri, 10 Nov 2017 16:56:42 -0600 Received: from STL3MSX02.corp.mastercard.org (172.19.129.91) by STLMSXP40.corp.mastercard.org (172.19.136.47) with Microsoft SMTP Server (TLS) id 14.3.224.2; Fri, 10 Nov 2017 16:56:42 -0600 Received: from STL3MSX01.corp.mastercard.org (172.19.129.90) by STL3MSX02.corp.mastercard.org (172.19.129.91) with Microsoft SMTP Server (TLS) id 15.0.1347.2; Fri, 10 Nov 2017 17:56:41 -0500 Received: from STL3MSX01.corp.mastercard.org ([172.19.140.50]) by STL3MSX01.corp.mastercard.org ([172.19.140.50]) with mapi id 15.00.1347.000; Fri, 10 Nov 2017 16:56:41 -0600 From: "Huang, Zhipeng" To: "user@storm.apache.org" Subject: storm flux API - emit to specific streamId Thread-Topic: storm flux API - emit to specific streamId Thread-Index: AdNadVp51AmgireWSYyRI1dpXE2eWAAAasnQ Date: Fri, 10 Nov 2017 22:56:41 +0000 Message-ID: <724d95a8f5ee43c7b445f1e1582610b2@STL3MSX01.corp.mastercard.org> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-ms-exchange-transport-fromentityheader: Hosted x-originating-ip: [172.17.129.22] x-mcsrcsvr: MCNSTL05 x-disclaimer: Yes Content-Type: multipart/alternative; boundary="_000_724d95a8f5ee43c7b445f1e1582610b2STL3MSX01corpmastercard_" MIME-Version: 1.0 X-CFilter-Loop: Forward archived-at: Fri, 10 Nov 2017 22:56:48 -0000 --_000_724d95a8f5ee43c7b445f1e1582610b2STL3MSX01corpmastercard_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi Apache Storm Team, May I have a quick question - how to configure the streamId in yaml file, so in Bolt we can emit the tuple to specified stream? Thanks! Currently the StreamDef don't have "streamId" available in V1.1.1, or even = on Github. public class StreamDef { private String name; // not used, placeholder for GUI, etc. private String from; private String to; private GroupingDef grouping; Regards, Jude CONFIDENTIALITY NOTICE This e-mail message and any attachments are only for= the use of the intended recipient and may contain information that is priv= ileged, confidential or exempt from disclosure under applicable law. If you= are not the intended recipient, any disclosure, distribution or other use = of this e-mail message or attachments is prohibited. If you have received t= his e-mail message in error, please delete and notify the sender immediatel= y. Thank you. --_000_724d95a8f5ee43c7b445f1e1582610b2STL3MSX01corpmastercard_ Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable

Hi Apache Storm Team,

 

May I have a quick question – how to configure= the streamId in yaml file,

so in Bolt we can emit the tuple to specified stream= ? Thanks!

 

 

Currently the StreamDef don’t have “stre= amId” available in V1.1.1, or even on Github.

 

public class StreamDef {

 

    private String = name; = // not used, placeholder for GUI, etc.

    private String = from;=

    private String = to= ;

private GroupingDef = grouping;

 

 

Regards,

Jude

CONFIDENTIALITY NOTICE This e-mail message and any attachments are only for= the use of the intended recipient and may contain information that is priv= ileged, confidential or exempt from disclosure under applicable law. If you= are not the intended recipient, any disclosure, distribution or other use of this e-mail message or attach= ments is prohibited. If you have received this e-mail message in error, ple= ase delete and notify the sender immediately. Thank you. --_000_724d95a8f5ee43c7b445f1e1582610b2STL3MSX01corpmastercard_--