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

RemoteExecutor

Trait for executing plan nodes on remote workers.

Functions

execute

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

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.