Wow. Good work Storm people! Some nice features here.
Anyone privy to what changes they made to yield the performance improvements?
Anyone privy to what changes they made to yield the performance improvements?
"Profiling a simple speed of light topology, shows that a good chunk of time of the SpoutOutputCollector.emit() is spent in the clojure reduce() function.. which is part of the ACK-ing logic. Re-implementing this reduce() logic in java gives a big performance boost in both in the Spout.nextTuple() and Bolt.execute()"