Skip to main content

Module types

Module types 

Source

Structs§

CachePolicy
Cache policy for task results
Command
Command for controlling graph execution
GraphInterrupt
Error type for graph interrupts
Interrupt
An interrupt value surfaced to the client
InterruptError
Error type returned by interrupt().
Overwrite
Overwrite bypasses the reducer and writes directly
PregelExecutableTask
The full task ready for execution
PregelScratchpad
Scratchpad for tracking interrupt state during execution.
PregelTask
Lightweight task descriptor (for state queries)
RetryPolicy
Retry policy for task execution
Send
Send a message to a target node (for map-reduce patterns)
StateSnapshot
State snapshot returned by get_state()

Enums§

CommandGoto
Durability
Durability mode for checkpoint writes
StreamMode
Stream mode

Functions§

interrupt
Interrupt the current graph execution with a value.