storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "A.M." <>
Subject Trident topology: sliding window aggregation?
Date Wed, 23 Jul 2014 17:30:40 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?



View raw message