Storm的spout中如何将tuple发给指定的Blot?

[复制链接]
查看11 | 回复1 | 2021-1-27 05:40:48 | 显示全部楼层 |阅读模式
比如下图,我想将Spout中的某些tuple发给BlotA,某些tuple发给BlotC。怎么指定呢?多谢



分 -->
回复

使用道具 举报

千问 | 2021-1-27 05:40:48 | 显示全部楼层
这个太简答了,在Spout中通过SpoutOutputCollectorcollector来进行发送,collector.emit方法里就提供了针对不同的方向进行发送。emit(java.lang.StringstreamId,java.util.Listtuple)
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

主题

0

回帖

4882万

积分

论坛元老

Rank: 8Rank: 8

积分
48824836
热门排行