The operator ensures the order of tuples. It collects all tuples in input until a heartbeat-punctuation is received, then it writes all collected tuples to output in the correct order. So the ordered output contains all tuples which were received after the last received heartbeat-punctuation. There has to be an ASSUREHEARTBEAT operator an operator that send an HEARTBEAT before this operator.
Example
Code Block | |||||||
---|---|---|---|---|---|---|---|
| |||||||
ordered_output = ASSUREORDERREORDER(input) |
Remark: Renamed from AssureOrder