GitHub user mjsax opened a pull request:
https://github.com/apache/storm/pull/694
[STROM-855] Add tuple batching
- added parameter "batch_size" to TopologyBuilder
- added Batch class
- adopted Kryo (de)serialization for Tuple and Batch
- added Spout/Bolt output batching
- added Bolt input debatching
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/storm batching
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/694.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 #694
----
commit 502951dfd8b85f9099d7f786bccae41dace67146
Author: mjsax <[email protected]>
Date: 2015-06-15T23:09:10Z
added parameter "batch_size" to TopologyBuilder
commit 244a826c5e4b2ae8b9067a174c84b07fc6d1f1d0
Author: mjsax <[email protected]>
Date: 2015-08-20T16:18:28Z
added Batch class
commit 6e7e61668cbcc6419134d529a817f95339871ac8
Author: mjsax <[email protected]>
Date: 2015-08-20T16:19:02Z
adopted Kryo (de)serialization for Tuple and Batch
commit c08ab9ce77307ef59e9322e31d00daea3e4d2230
Author: mjsax <[email protected]>
Date: 2015-08-20T16:20:25Z
[STROM-855] Add tuple batching
- added Spout/Bolt output batching
- added Bolt input debatching
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
