If I use a non-zero value for allowedLateness and also sideOutputLateData,
does the late data output contain also the events that were triggered in
the bounds of allowed lateness? By looking at the docs I can't be sure
which way it is.

Code example:

.timeWindow(Time.days(1))
.allowedLateness(Time.minutes(1))
.sideOutputLateData(lateDataTag)

Also I know that data that arrives more than 1 minute late is written to
the late data side output.

If some data arrives 0-1 minute late, I know that the time window triggers
again with that data added. Is that data also written to the late data side
output or not?

Thanks!

Reply via email to