Hi Padma, Firstly, thanks for responding.
Here is how i am defining my topology conceptually.. - Spout waits for a request signal.. - once spout got a signal, it generates a request_id and broadcasts that request_id to 10 csv reader bolts.. - 10 csv reader bolts reads csv files line-by-line and emits those tuples, respectively.. - Now (this is the place where i need suggestion in technical/syntactical) i need to batch up those tuples from all the 10 csv reader bolts on specified fields.. - finally, batch-ed tuples will be processed by final bolts. What i need is a technical approach. On Tuesday, 6 May 2014 11:10 AM, padma priya chitturi <[email protected]> wrote: 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 <[email protected]> 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. > > >
