Types

Configuration for retrying nodes.

Configuration for caching nodes.

Information about an interrupt that occurred in a node.

A Pregel task.

Snapshot of the state of the graph at the beginning of a step.

A message or packet to send to a specific node in the graph.

One or more commands to update the graph's state and send messages to nodes.

Bypass a reducer and write the wrapped value directly to a BinaryOperatorAggregate channel.

Type of the checkpointer to use for a subgraph.

Special value to indicate that graph should interrupt on all nodes.

How the stream method should emit outputs.

Callable that accepts a single argument and writes it to the output stream.