GitHub user raviperi opened a pull request: https://github.com/apache/storm/pull/2322
Introduce config params to use latest EH client, control request prefetch size, batch size of events received per call. -Refactor the code to group classes more appropriately -Remove redundant types -Javadoc comments where applicable -Preftch config parameter to dictate EH prefetch count -config parameter to introduce sleep between spout's nexttuple calls -config parameter to retrieve a batched number of events per call to EH (opposed to single event) -New data scheme to group event payload and audit params into a single type, and expose the single type as the only tuple field to downstream bolts. You can merge this pull request into a Git repository by running: $ git pull https://github.com/raviperi/storm master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/storm/pull/2322.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2322 ---- commit e9fc45d3d604b65ab3e99895b4a7711bf1b7ab30 Author: Ravi Peri <ravip...@microsoft.com> Date: 2017-09-11T21:35:48Z Introduce config params to dictate EH request prefetch size, max number of events received per call. -Refactor the code to group classes more appropriately -Remove redundant types -Javadoc comments where applicable -Preftch config parameter to dictate EH prefetch count -config parameter to introduce sleep between spout's nexttuple calls -config parameter to retrieve a batched number of events per call to EH (opposed to single event) -New data scheme to group event payload and audit params into a single type, and expose the single type as the only tuple field to downstream bolts. ---- ---