Expand description
utilities for managing state of dataflow execution
Structs§
- Arrange
Handler - A handler to the inner Arrangement, can be cloned and shared, useful for query it’s inner state
- Arrangement
- A shared state of key-value pair for various state in dataflow execution.
- KeyExpiry
Manager - Determine when should a key expire according to it’s event timestamp in key.
- Size
Report Sender
Functions§
- compact_
diff_ 🔒row - get_
value_ heap_ size - Get a estimate of heap size of a value
Type Aliases§
- Arrange
Reader - Simply a type alias for ReadGuard of Arrangement
- Arrange
Writer - Simply a type alias for WriteGuard of Arrangement
- Batch
- A batch of updates, arranged by key
- Spine
- A spine of batches, arranged by timestamp TODO(discord9): consider internally index by key, value, and timestamp for faster lookup
- State
Report Handler - Handle the size report request, and send the report back