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 <[email protected]>
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.
----
---