Storm 中Fields有什么用
发表于:2024-10-21 作者:千家信息网编辑
千家信息网最后更新 2024年10月21日,今天就跟大家聊聊有关Storm 中Fields有什么用,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。TransactionalTopology
千家信息网最后更新 2024年10月21日Storm 中Fields有什么用
今天就跟大家聊聊有关Storm 中Fields有什么用,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
TransactionalTopologyBuilder builder = new TransactionalTopologyBuilder("test", "spout", new TweetsTransactionalSpout()); builder.setBolt("users-splitter", new UserSplitterBolt(), 4).shuffleGrouping("spout");builder.setBolt("hashtag-splitter", new HashtagSplitterBolt(), 4).shuffleGrouping("spout"); builder.setBolt("user-hashtag-merger", new UserHashtagJoinBolt(), 4) .fieldsGrouping("users-splitter","users", new Fields("tweet_id")) .fieldsGrouping("hashtag-splitter", "hashtags", new Fields("tweet_id"));
这里有两个bolt在向user-hashtag-merger发送数据,两个bolt在 emit的时候可能发送了不同的tuple比如:
users-splitter中emit(new Values(a, b, c)); declarer.declare(new Fields("id", "name", "tweet_id"));
hashtag-splitter中则emit(new Values(a, b)); declarer.declare(new Fields("id", "tweet_id"));
比如user-hashtag-merger中需要的是users-splitter中的c,hashtag-splitter 中的b,而在user-hashtag-merger
中接收数据的时候无法知道数据是哪个bolt发来的(或者就算知道,发来的数据格式不一样也不是一个好的设计)所以这边设定了一个
Fields,这样在发送数据的时候只发送指定Fields的数据,比如这边user-hashtag-merger不管前面bolt emit的时候
发送了什么,最后收到的只有一个,方便处理。
builder.setBolt("redis-committer", new RedisCommiterCommiterBolt()) .globalGrouping("users-splitter","users") .globalGrouping("hashtag-splitter", "hashtags") .globalGrouping("user-hashtag-merger");
看完上述内容,你们对Storm 中Fields有什么用有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注行业资讯频道,感谢大家的支持。
数据
时候
内容
两个
不同
只有
更多
格式
知识
篇文章
行业
资讯
资讯频道
频道
进一
处理
支持
有关
设计
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
基于linux建立服务器
怎样隐藏服务器远程端口
软件开发模型项目
办税大厅网络安全应急预案
必信网络技术公司诈骗
猫和老鼠到底怎么连服务器
手机邮箱服务器设置安全类型
数据库运维都学什么
数据库整形类型是什么
网络技术研发交什么税
数据库数据文件被删除怎么恢复
广阔的数据库
暗黑不朽a测服务器
煤矿信息中心网络安全
如何选择复制筛选后的数据库
出租车叫车软件开发公司
阿里云服务器与本地电脑组网
怎么插入数据库表
广州市薇恩互联网科技有限公司
我的世界数码宝贝服务器群号
软件开发推广财务分析
网络技术人员工作经验
宁德采购机器人rpa软件开发
网络安全支付法律
奉化应用软件开发设计
网络安全宣讲团
日照卓信网络技术
软件开发用家庭版
滨州陶瓷软件开发服务
数据库需求分析 图书馆