You should use an Aggregator if you want to process many tuples within a batch, or a State and a StateUpdater if you want to process many tuples across batches.
On Wed, Jan 28, 2015 at 9:55 AM, Pandian R <[email protected]> wrote: > Hi, > > I am implementing a trident topology and using functions at many steps(as > alternative to traditional bolts). But, I don't find a startBatch and > finishBatch function. I need to do some operations per batch within a > function. Function has prepare and cleanup which is called per tuple. Can > someone help how to implement startBatch and finishBatch functions in a > Function ? > > Thanks ! > > -- > Regards, > Pandian > -- Twitter: @nathanmarz http://nathanmarz.com
