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

Reply via email to