Re: How to count Tuples in each batch

2015-06-04 Thread Ashish Soni
Try below as it will print count by batch . TridentTopology topology = new TridentTopology(); topology.newStream("cdrevent", new CSVSpout("testdata.csv", ',', false)).partitionBy(new Fields("field_1")). groupBy(new Fields("field_1")) .aggregate(new Fields("field_1"), new Count(),new Fields("coun

How to count Tuples in each batch

2015-06-04 Thread nitin sharma
Hi All, I would like to know how many tuples are getting processed in a batch... is there a way to do so.. may be something i can code in execute() method and print in log? Regards, Nitin Kumar Sharma.