Strange problem, I can't receive reply of my question to email list. I read
ansewer from strom website. Thanks for
Stig Rohde Døssing. That's very helpful.
------------------ Original ------------------
From: "ChenBo"<mrche...@qq.com>;
Date: Fri, Nov 23, 2018 11:51 AM
To: "user"<user@storm.apache.org>;
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
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
