storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "A.M." <costco.s...@yahoo.com>
Subject Re: use normal storm bolt in trident topology
Date Wed, 23 Jul 2014 17:28:05 GMT
While looking into storm Trident, how could we achieve sliding window functions with Trident
topology as demoed in Spark Streaking:

val tagCounts = hashTags.window(Minutes(10), Seconds(1)).countByValue()


I've read about the regular storm topology using tick tuples to do the sliding window. In
trident, how could we do the same?
Thanks.




-Costco
Mime
View raw message