如何在风暴中将元组发送到不同的印迹

Question

everyone.I want to do the job——一个spout向blotA发出数字，BlotA向Blot_odd发出奇数，BlotA向Blot_even发出偶数。 我选择了一种方式使用emit(streamId,tuple)，但不知道在哪里定义我的streamId？

在 Blot_odd / Blot_even 中，

declareOutputFields(){declarer.declareStream("streamId", new Fields("fieldName"));}

在main 的MyTopology.java 中

main() {
    TopologyBuilder builder = new TopologyBuilder();
    builder.setSpout("num", new NumSpout(), 10);
    builder.setBolt("judge", new Bolt(), 3).shuffleGrouping("num");
    builder.setBolt("odd", new Bolt_odd(), 2).shuffleGrouping("judge");
    builder.setBolt("even", new Bolt_even(), 2).shuffleGrouping("judge");
}

但我失败了。

Answer 1

你可以像下面那样做。

在 Bolt 的 declareOutputFields 方法中，这样填写细节。

declarer.declareStream("oddstream", new Fields("fieldName"));
declarer.declareStream("evenstream", new Fields("fieldName"));

你可以像下面这样声明拓扑。

builder.setSpout("num", new NumSpout(), 10);
builder.setBolt("judge", new Bolt(), 3).shuffleGrouping("num");
builder.setBolt("odd", new Bolt_odd(), 2).shuffleGrouping("judge", "oddstream");
builder.setBolt("even", new Bolt_even(), 2).shuffleGrouping("judge", "evenstream");