I bump the thread as I'm also looking for the answer to this question. If anyone has any ideas to share, that would be great!
Thanks, - Zarzyk 2014-07-23 19:30 GMT+02:00 A.M. <[email protected]>: > 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 > >
