storm_使用streamid的例子

客官°小女子只卖身不卖艺 2022-04-11 13:21 206阅读 0赞

有时同一个spout或者bolt需要发出多类不同的消息。如对一个字串拆分为单词后，将各单词一一发送给各节点，发送完后再发送一条结束的任务。

使用方法如下：

**1.S****pout****的declareOutputFields****方法****中定义多组stream：**

@Override

**public** **void** declareOutputFields(OutputFieldsDeclarer declarer) \{

declarer.declareStream("working",**new** Fields("word", "key"));

declarer.declareStream("stop", **new** Fields("key"));

\}

在emit时指定streamid，第一个参数。如

\_collector.emit("working", **new** Values(word, fileName));

\_collector.emit("stop", **new** Values(fileName));

注，是第一个参数，和tupleId不是一回事，tupleId是在values参数后面。

**2.B****olt****如何使用****呢****：**

**public** **void** execute(Tuple tuple) \{

String streamId = tuple.getSourceStreamId();

**if** (streamId.equals("working"))\{

\}

**if** (streamId.equals("stop"))\{

\}

\}

**3.T****opology中如何定义呢：**

在流分组的第二个参数上：

builder.setSpout("wordSpout", **new** WordSpout(), 4);

builder.setBolt("CountBolt", **new** CountBolt(), 4)

.fieldsGrouping("wordSpout", "working", **new** Fields("word"))

.allGrouping("wordSpout", "stop");

发表评论取消回复

表情：

评论列表（有 0 条评论，206人围观）

还没有评论，来说两句吧...

相关阅读

相关 sshpass的使用例子

[sshpass的使用][sshpass]例子例子： sshpass：用于非交互的ssh 密码验证使用 -p 参数指定明文密码，然后直接登录远程服务

r囧r小猫/ 2023年01月20日 13:48/ 0 赞/ 137 阅读

相关 flume+kafka+storm的集成使用

Flume-ng Flume是一个分布式、可靠、和高可用的海量日志采集、聚合和传输的系统。 Flume的文档可以看[http://flume.apache.org/Flum

港控/mmm°/ 2022年06月18日 11:25/ 0 赞/ 191 阅读

相关 Storm安装和使用Demo

http://blog.csdn.net/sqh201030412/article/details/78426812 一,Storm集群的安装 1.下载安

悠悠/ 2022年06月05日 01:40/ 0 赞/ 199 阅读

相关 Storm Trident API 使用详解

一、概述 Storm Trident中的核心数据模型就是“Stream”，也就是说，Storm Trident处理的是Stream，但是实际上Stream是被成批

小咪咪/ 2022年06月02日 23:25/ 0 赞/ 270 阅读

相关 storm_可靠消息的例子

这是一个比较复杂的例子，含盖的知识面较多。需求：统计出某文件夹下各文件中，各个单词出现的数次。（同时将文件剪切到另一个目录）知识点一：多进程/多线程读取同一个文件，需要

忘是亡心i/ 2022年04月11日 13:22/ 0 赞/ 244 阅读

相关 storm_使用streamid的例子

有时同一个spout或者bolt需要发出多类不同的消息。如对一个字串拆分为单词后，将各单词一一发送给各节点，发送完后再发送一条结束的任务。使用方法如下： 1.Spout的

客官°小女子只卖身不卖艺/ 2022年04月11日 13:21/ 0 赞/ 207 阅读

相关 storm_简单的例子

写一个简单的topology，spout处理各单词，第一组bolt给各单词后面添加!!!，然后汇聚到同一个bolt并记录所有的单词及个数。 ![watermark_type_

缺乏、安全感/ 2022年04月11日 13:21/ 0 赞/ 278 阅读

相关 SpringJdbc使用的例子

package com.test; import org.springframework.jdbc.core.JdbcTemplate;

ゞ浴缸里的玫瑰/ 2021年12月01日 13:36/ 0 赞/ 316 阅读

相关 Storm系列（二）：使用Csharp创建你的第一个Storm拓扑（wordcount）

WordCount在大数据领域就像学习一门语言时的hello world，得益于Storm的开源以及[Storm.Net.Adapter][]，现在我们也可以像Java或Pyt

Love The Way You Lie/ 2021年11月09日 07:52/ 0 赞/ 239 阅读

相关 storm定时任务使用实例

\[http://twitter.github.io/heron/docs/getting-started/\] 1.背景需要在bolt中定时执行某些操作 2.方法

﹏ヽ暗。殇╰゛Y/ 2021年10月18日 09:52/ 0 赞/ 316 阅读