Struct WorkerCompute 

pub struct WorkerCompute { /* private fields */ }

Runs wasm / container steps on a shared fv_compute::Runtime.

Implementations

impl KineticsRunner

pub fn new(runtime: Arc<Runtime>) -> KineticsRunner

pub fn runtime(&self) -> &Arc<Runtime>

The runtime this runner dispatches to.

pub fn selector(step: &Value) -> Result<&str, String>

The transform a compute step selects: its ref (or legacy transform) field.

pub fn ensure_loadable(&self, step: &Value) -> Result<(), String>

Resolve and load the step’s transform without running it. Call this when a pipeline or stream is configured, so a missing or broken transform fails there rather than per batch.

pub fn run_sync( &self, step: &Value, inputs: &[(String, Vec<Row>)], ) -> Result<Vec<Row>, String>

Run a compute step synchronously. The transform backends are synchronous (a component call, or a blocking child process), so this needs no async runtime; the async ComputeRunner impl is a thin wrapper.

Trait Implementations

impl Clone for KineticsRunner

fn clone(&self) -> KineticsRunner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ComputeRunner for KineticsRunner

fn run<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, step: &'life1 Value, inputs: &'life2 [(String, Vec<Row>)], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, KineticsRunner: 'async_trait,