Thanks. Tried using an Aggregator first, but using aggregator loses the original fields in the tuple and forwards only the new fields to the output stream.
On Wed, Jan 28, 2015 at 8:44 PM, Nathan Marz <[email protected]> wrote: > 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 > -- Regards, Pandian
