flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: Query regarding tumbling event time windows with ingestion time
Date Wed, 30 Nov 2016 10:04:28 GMT
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.reddy@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


Mime
View raw message