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 timestamp field.
Can anyone tell me how to set timestamp field in trident TumblingDurationWindow?
Any help is appreciated. Thanks,
ChenBo
