pub struct LocalRunner;Expand description
Executes plans locally — same logic for local and remote execution.
Trait Implementations§
Source§impl Runner for LocalRunner
impl Runner for LocalRunner
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>)>
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>
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.
Auto Trait Implementations§
impl Freeze for LocalRunner
impl RefUnwindSafe for LocalRunner
impl Send for LocalRunner
impl Sync for LocalRunner
impl Unpin for LocalRunner
impl UnsafeUnpin for LocalRunner
impl UnwindSafe for LocalRunner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more