diff --git a/streamparse/storm/bolt.py b/streamparse/storm/bolt.py index 1e688e84..87f46c7b 100644 --- a/streamparse/storm/bolt.py +++ b/streamparse/storm/bolt.py @@ -237,6 +237,7 @@ def _handle_run_exception(self, exc): if self.auto_fail: self.fail(tup) + class BatchingBolt(Bolt): """A bolt which batches Tuples for processing.