Struct rlink::functions::source::vec_input_format::IteratorInputFormat [−][src]
pub struct IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>, { /* fields omitted */ }
Implementations
impl<T> IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
Trait Implementations
impl<T> CheckpointFunction for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> CheckpointFunction for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
fn consult_version(
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
trigger the method when a operator
initialization
trigger the method when the operator
operate a Barrier
event
impl<T> Debug for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> Debug for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> InputFormat for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> InputFormat for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
Initialization of InputFormat
, Each task will be called once when it starts.
return an Iterator
of Record
, if the next
of Iterator
is None
,
the task of InputFormat
will be Terminated
.
the function is called by element_iter
, a user-friendly function,
usually you just need to implement it Read more
return an Iterator
of Element
, if the next
of Iterator
is None
,
the task of InputFormat
will be Terminated
.
the function is called by runtime Read more
impl<T> InputSplitSource for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> InputSplitSource for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> NamedFunction for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
impl<T> NamedFunction for IteratorInputFormat<T> where
T: FnOnce(InputSplit, Context) -> Box<dyn Iterator<Item = Record> + Send>,
Auto Trait Implementations
impl<T> RefUnwindSafe for IteratorInputFormat<T> where
T: RefUnwindSafe,
impl<T> Send for IteratorInputFormat<T> where
T: Send,
impl<T> Sync for IteratorInputFormat<T> where
T: Sync,
impl<T> Unpin for IteratorInputFormat<T> where
T: Unpin,
impl<T> UnwindSafe for IteratorInputFormat<T> where
T: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self