Can you explain in below example as i want to do the CSV spilt as shuffle
and then partition ...
topology.newStream("cdrevent", new CSVSpout("testdata.csv", ',', false)).
groupBy(new Fields("field_1"))
.aggregate(new Fields("field_1"), new Count(),new Fields("count"))
.parallelismHint(5).each(new Fields("field_1","count"), new
Utils.PrintFilter());
On Mon, Jun 1, 2015 at 10:32 AM, Denis DEBARBIEUX <[email protected]>
wrote:
> Dear,
>
> If your question is about the syntax (in Java), shuffle and field grouping
> are methods of the type Stream.
>
> Denis
>
>
> Le 01/06/2015 16:27, Ashish Soni a écrit :
>
> Hi All ,
>
> It is not clear to me how can i use shuffle and field grouping with
> Trident Topology , It would be helpful if some one can explain or point me
> towards some examples.
>
> Regards,
>
>
>
>
> ------------------------------
> <http://www.avast.com/>
>
> L'absence de virus dans ce courrier électronique a été vérifiée par le
> logiciel antivirus Avast.
> www.avast.com
>
>
