Structs§
- Cache
Policy - Cache policy for task results
- Command
- Command for controlling graph execution
- Graph
Interrupt - Error type for graph interrupts
- Interrupt
- An interrupt value surfaced to the client
- Interrupt
Error - Error type returned by
interrupt(). - Overwrite
- Overwrite bypasses the reducer and writes directly
- Pregel
Executable Task - The full task ready for execution
- Pregel
Scratchpad - Scratchpad for tracking interrupt state during execution.
- Pregel
Task - Lightweight task descriptor (for state queries)
- Retry
Policy - Retry policy for task execution
- Send
- Send a message to a target node (for map-reduce patterns)
- State
Snapshot - State snapshot returned by get_state()
Enums§
- Command
Goto - Durability
- Durability mode for checkpoint writes
- Stream
Mode - Stream mode
Functions§
- interrupt
- Interrupt the current graph execution with a value.