pub trait Node {
type Input;
type Output;
fn process(&mut self, input: Vec<Self::Input>) -> Vec<Self::Output>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
;
fn reset(&mut self) { ... }
fn data_remaining(&self) -> usize { ... }
fn add_node<N: Node<Input = Self::Output>>(
self,
node: N
) -> Connector<Self, N>
where
Self: Sized,
{ ... }
fn add_batch_fn<O, F: Fn(Vec<Self::Output>) -> Vec<O>>(
self,
function: F
) -> Connector<Self, BatchStateless<Self::Output, O, F>>
where
Self: Sized,
{ ... }
fn add_fn<O, F: Fn(Self::Output) -> O + Send + Sync>(
self,
function: F
) -> Connector<Self, SingleStateless<Self::Output, O, F>>
where
Self: Sized,
{ ... }
fn split<N3: Node<Input = Self::Output>, N4: Node<Input = Self::Output>>(
self,
node1: N3,
node2: N4
) -> Connector<Connector<Self, Duplicator<Self::Output>>, Pair<N3, N4>>
where
Self: Sized,
Self::Output: Clone,
{ ... }
fn pair<O1, O2, N3: Node<Input = O1>, N4: Node<Input = O2>>(
self,
node1: N3,
node2: N4
) -> Connector<Self, Pair<N3, N4>>
where
Self: Sized,
Self: Node<Output = (O1, O2)>,
{ ... }
}
Associated Types
Required methods
Provided methods
fn data_remaining(&self) -> usize
fn data_remaining(&self) -> usize
Get number of examples left
fn add_batch_fn<O, F: Fn(Vec<Self::Output>) -> Vec<O>>(
self,
function: F
) -> Connector<Self, BatchStateless<Self::Output, O, F>> where
Self: Sized,
fn add_batch_fn<O, F: Fn(Vec<Self::Output>) -> Vec<O>>(
self,
function: F
) -> Connector<Self, BatchStateless<Self::Output, O, F>> where
Self: Sized,
Add function to pipeline
Add function that takes a single datapoint and outputs a single datapoint