Hi Janardhan,
After the first windowing operation, the timestamp of the emitted element for
each window
will be the (endOfWindow - 1). So in your case, in the second windowing
operation (window by 5)
there will be at most one element per window.
I hope this answers your question.
Kostas
> On Nov 29, 2016, at 7:25 PM, Janardhan Reddy <janardhan.re...@olacabs.com>
> wrote:
>
> Hi,
>
> Suppose we have a stream like this.
>
> someStream.timeWindow(Time.minutes(15)).apply {
> operation A
>
> }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
>
> operation B
>
> }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
>
> operation C
>
> }
>
> Say operation A emits some elements => it would be emitted every 15 minutes.
>
> How would be the window behaviour of where operation B takes place if
> operation A takes more than 5 seconds with ingestion Time characteristic.
> Similarly how would windows behave near operation C if operation B takes more
> than 5 seconds.
>
>
> Thanks
> Janardhan
