Implements test cases to demonstrate out-of-order processing and adds architecture document for processing out-of-order tuples in allowed lateness.
Implements workaround to return windows from allowed lateness until lastWatermark again, if an out-of-order tuple in allowed lateness has arrived.
Variable resendWindowsInAllowedLateness can be set to true by function setResendWindowsInAllowedLateness in SlicingWindowOperator at initialization.
Upon the arrival of an out-of-order tuple in allowed lateness, lastWatermark is set to allowed lateness.
Implements test cases to demonstrate out-of-order processing and adds architecture document for processing out-of-order tuples in allowed lateness.
Implements workaround to return windows from allowed lateness until lastWatermark again, if an out-of-order tuple in allowed lateness has arrived. Variable
resendWindowsInAllowedLatenesscan be set to true by functionsetResendWindowsInAllowedLatenessin SlicingWindowOperator at initialization. Upon the arrival of an out-of-order tuple in allowed lateness, lastWatermark is set to allowed lateness.