java - Storm Bolt 中跨任务的变量

Question

字段分组可以将具有某些字段的元组定向到同一任务。一个执行器可以包含多个任务。

如果我声明一个带有私有(private)变量整数的bolt来计算元组。

public static class CountBolt implements IRichBolt {
    OutputCollector _collector;
    private int count;

    public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
        _collector = collector;
        count = 0;
    }

    public void execute(Tuple tuple) {
        count = count + 1;
        _collector.ack(tuple);
    }

    public void cleanup() {
    }

    public void declareOutputFields(OutputFieldsDeclarer declarer) {
    }

    public Map getComponentConfiguration() {
        return null;
    }
}

此计数是否显示同一任务或同一执行器的输入总数？

Answer 1

计数将按每个任务进行。每个任务都有自己的 Spout/Bolt 类实例。

如果变量被声明为静态，则它将针对每个工作人员。 (不是每个执行器，因为一个工作线程可能运行同一个 Spout/Bolt 的多个执行器。)