Re: How to count Tuples in each batch
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
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.