Hello!
I'm currently using Apache Storm 0.9.4 and have question about
thread-safety of *SpoutOutputCollector*. Is it safe to call *emit *method
from different threads?
In documentation (http://storm.apache.org/documentation/Concepts.html) it
is said that *OutputCollector *is not thread-safe, and all emits, acks, and
fails must happen on the same thread.
But in Javadoc (
https://storm.apache.org/apidocs/backtype/storm/spout/ISpout.html) it is
said that *SpoutOutputCollector* is thread-safe and should be saved as an
instance variable of this spout object.
Please, provide a little bit more details about thread-safety of
*SpoutOutputCollector* and validity of calling *emit *method from different
threads.
Thanks.
Best regards,
Evgeniy
|