You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Remi Raymond <rr...@thinkingphones.com> on 2015/02/12 22:54:18 UTC

Is a Trident Aggregator's aggregate method called by multiple threads?

Hi,

So we have a Trident Aggregator. The class as an internal buffer that it
uses to aggregate messages passed to its aggregate method. Right now the
buffer is a ByteBuffer which isn't thread safe.

Is there ever more than one thread calling the methods off that Aggregator?
If so, I guess we'd need to put a sync block around the buffer...

Thanks!