THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Ad-hoc vs continuous spilling
Avoiding double processing in downstream (if continuous spilling)
- downstream reads upstream buffers and filters out what it has already processed; files are indexed
- downstream communicates its offset to upstream during snapshotting
- downstream communicates its offset to upstream during recovery
Existing persistence mechanisms vs custom
...