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
