Skip to main content

Runner

somatize_runtime::runner

Trait Runner 

Source 
pub trait Runner: Send + Sync {
    // Required methods
    fn fit(
        &self,
        plan: &ExecutionPlan,
        filters: &FilterLibrary,
        cache: &dyn CacheStore,
        event_bus: &Arc<EventBus>,
        input: &Value,
        y: Option<&Value>,
    ) -> Result<(Value, HashMap<String, Value>)>;
    fn forward(
        &self,
        plan: &ExecutionPlan,
        filters: &FilterLibrary,
        cache: &dyn CacheStore,
        event_bus: &Arc<EventBus>,
        input: &Value,
    ) -> Result<Value>;
}
Expand description

Contract for executing plans. Every execution mode (local, remote, stream) implements this trait. One interface, polymorphic dispatch.

Required Methods§

Source

fn fit( &self, plan: &ExecutionPlan, filters: &FilterLibrary, cache: &dyn CacheStore, event_bus: &Arc<EventBus>, input: &Value, y: Option<&Value>, ) -> Result<(Value, HashMap<String, Value>)>

Train: fit each filter, forward to propagate outputs. Returns (last output, all node outputs).

Source

fn forward( &self, plan: &ExecutionPlan, filters: &FilterLibrary, cache: &dyn CacheStore, event_bus: &Arc<EventBus>, input: &Value, ) -> Result<Value>

Inference: forward data through the compiled plan.

Implementors§