Struct dataflow::pipeline::KeyedLoader
source · [−]pub struct KeyedLoader { /* private fields */ }
Expand description
A loader with a key generating function
Implementations
Trait Implementations
sourceimpl Node for KeyedLoader
impl Node for KeyedLoader
type Input = usize
type Output = String
sourcefn 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 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,
A: Allocator,
Process a batch of data
sourcefn data_remaining(&self) -> usize
fn data_remaining(&self) -> usize
Get number of examples left
fn add_node<N: Node<Input = Self::Output>>(self, node: N) -> Connector<Self, N> where
Self: Sized,
sourcefn 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
sourcefn add_fn<O, F: Fn(Self::Output) -> O + Send + Sync>(
self,
function: F
) -> Connector<Self, SingleStateless<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,
Add function that takes a single datapoint and outputs a single datapoint
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)>,
Auto Trait Implementations
impl RefUnwindSafe for KeyedLoader
impl Send for KeyedLoader
impl Sync for KeyedLoader
impl Unpin for KeyedLoader
impl UnwindSafe for KeyedLoader
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<T> Pointable for T
impl<T> Pointable for T
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more