The window start time would be based on which window the events falls into
(based on the window length and sliding interval that you set)
In the master branch you can access this start and end timestamps.
See
https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/windowing/Window.java#L88
But this does not work in 1.2.2 (will be available when Storm 2.0 comes out)
Thanks,
Arun
On Mon, 3 Dec 2018 at 22:22, ChenBo <mrchenbo@qq.com> wrote:
> Hi All, I use storm-core 1.2.2, I am little confuse about storm.
>
> In document, they say "When a watermark is received, all windows up to
> that timestamp will be evaluated."
>
> the question, when are the window start timestamp?
>
> Any help is appreciated.
>
> Thanks,
> ChenBo
>
>
|