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

Reply via email to