PregelNode

Default streaming implementation. Subclasses should override this method if they support streaming output.

Execute multiple operations in a single batch. This is more efficient than executing operations individually.

Run the graph with a single input and config.

Create a new runnable sequence that runs each individual runnable in series, piping the output of one runnable into another runnable or runnable-like.

Streams the execution of the graph, emitting state updates as they occur. This is the primary method for observing graph execution in real-time.

Stream modes:

• "values": Emits complete state after each step
• "updates": Emits only state changes after each step
• "debug": Emits detailed debug information
• "messages": Emits messages from within nodes
• "custom": Emits custom events from within nodes
• "checkpoints": Emits checkpoints from within nodes
• "tasks": Emits tasks from within nodes