この単語数はどのように安全ですか？

Question

私は嵐で新しいです、私は嵐の単語カウントの例を通過していた。ここに私の理解からカウントを追跡し、ボルト

public static class WordCount extends BaseBasicBolt { 
    Map<String, Integer> counts = new HashMap<String, Integer>(); 

    @Override 
    public void execute(Tuple tuple, BasicOutputCollector collector) { 
     String word = tuple.getString(0); 
     Integer count = counts.get(word); 
     if (count == null) 
     count = 0; 
     count++; 
     counts.put(word, count); 
     collector.emit(new Values(word, count)); 
    } 

    @Override 
    public void declareOutputFields(OutputFieldsDeclarer declarer) { 
     declarer.declare(new Fields("word", "count")); 
    } 
    } 

は、嵐が並行して実行ボルトのために複数のスレッドを起動しているので、どのようにここではスレッドセーフをHashMapの使用していますか？

Answer 1

[Bolts and spouts] do not need to be thread-safe. Each task has their own instance of the bolt or spout object they're executing, and for any given task Storm calls all spout/bolt methods on a single thread.