Module executor 

Plan executor — walks ExecutionPlan trees and runs filter nodes.

Handles sequential, parallel (scoped threads), cached, remote, loop, and branch execution. Uses GraphInfo for topology-aware input resolution.

Structs

Context

Execution context passed to filters during runtime.

GraphInfo

Graph topology information for input resolution.

Traits

Executable

Execute a compiled plan synchronously. For parallel branches, uses the async executor under the hood. Contract for executing a plan.

RemoteExecutor

Trait for executing plan nodes on remote workers.

Functions

execute

Execute a plan (convenience function, delegates to Executable trait).

resolve_input

Resolve the input for a node from the context store using graph topology. If a predecessor was spilled to DataStore, loads it back.