4 ms·
From the issue log : "Profiling a simple speed of light topology, shows that a good chunk of time of the SpoutOutputCollector.emit() is spent in the clojure r
by lovelearning 11y ago
From the issue log :
"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()"
[1]: https://issues.apache.org/jira/browse/STORM-1539 https://issues.apache.org/jira/browse/STORM-1539