Subject: how to set timestamp field in trident window?
Hi All, I use storm-core 1.2.2, and there is my code:
spoutStream.window(TumblingDurationWindow.of(new BaseWindowedBolt.Duration(10,
TimeUnit.SECONDS)),
new Fields("value"), new CountAsAggregator(), new
Also you should be aware of
https://issues.apache.org/jira/browse/STORM-3280 if you intend to use
Trident based windowing.
Den fre. 23. nov. 2018 kl. 12.10 skrev Stig Rohde Døssing <
stigdoess...@gmail.com>:
> I don't believe you can. The Trident windowing code seems to use
>
I don't believe you can. The Trident windowing code seems to use
System.currentTimeMillis without allowing you to set a timestamp extractor.
If you want to add this functionality, you should look at
Hi All, I use storm-core 1.2.2, and there is my code:
spoutStream.window(TumblingDurationWindow.of(new BaseWindowedBolt.Duration(10,
TimeUnit.SECONDS)),
new Fields("value"), new CountAsAggregator(), new
Fields("record"));
I can't find any API to specify window
