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 ASSUREHEARTBEATan HEARTBEAT operator before this operator.
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
ordered_output = ASSUREORDERREORDER(input) |
Remark: Renamed from AssureOrder