apache风暴，负载平衡，json

作者: Colin
发布时间: 2023-12-27 08:00:04 (4月前)
转自：

2 条回复

0#
回复此人
誓言 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我不确定您使用的是哪个版本的Storm，从0.9.4开始，您的要求可以如下实现。 </p> <pre> <code> builder.setBolt(MYDISTRIBUTEDWORKER, new DistributedBolt()).fieldsGrouping(SPOUTNAME, new Fields("groupid")); </code> </pre> <P> 在DistributedBolt的准备方法中， </p> <pre> <code> public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declare(new Fields("groupid", "log")); } </code> </pre> <P> 在执行方法的某个地方，你会打电话 </p> <pre> <code> collector.emit(new Values(groupid, log)); </code> </pre> <P> 那么具有相同groupid的元组将被传递给下一个bolt的同一个实例。 </p> </DIV>

编辑

登录后才能参与评论