Hi, You can define spouts and bolts in such a way that, input streams read by spouts would be grouped on specified fields and these could be processed by specific bolts. This way, you could make batches of input stream.
On Tue, May 6, 2014 at 11:02 AM, Kiran Kumar <kirankumardas...@ovi.com>wrote: > Hi, > > Can anyone suggest me a topology that makes batches of the input stream on > specified fields. so that the batch will be forwarded to a function that > processes it. > > Regards, > Kiran Kumar Dasari. >
