| Message view | « Date » · « Thread » |
|---|---|
| Top | « Date » · « Thread » |
| From | "A.M." <costco.s...@yahoo.com> |
| 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? Thanks. -Costco | |
| Mime |
|
| View raw message | |