Hi all I have prototypes using bolts and spout for an aggregation on multiple fields. Works fine. when i try to do using trident, i seem to be stuck.
a. Looks like i would like to use Aggregator interface but this is not supported in persistentAggregate methods. b. Can one use a combination of Aggregator and persistentAggregate on stream to do aggregation on multiple fields in set of tuples c. Also i see number of examples using DRPC immediately after building persistentAggregate code. But what i also read is that DRPC is deprecated. This is confusing at the least. Basically i am looking for a way to do agg on set of tuples grouped by multi fields in such a way that i can buffer for the current minute and flush for previous minute - like tick tuples in bolts. Just that trident documentation seems to be confusing as of now. Any help is appreciated. -- Regards Swaroop Belur
