pub struct ParallelOneInOneOutContext<'a, S, T, U> where
S: AppendableState<U>,
T: Data + for<'b> Deserialize<'b>, { /* private fields */ }
Expand description
A context structure made available to the callbacks of a ParallelOneInOneOut
operator. The
context provides access to the current timestamp for which the callback is invoked along with
the state of the operator and the write stream to send the outputs on.
Implementations
sourceimpl<'a, S, T, U> ParallelOneInOneOutContext<'a, S, T, U> where
S: AppendableState<U>,
T: Data + for<'b> Deserialize<'b>,
impl<'a, S, T, U> ParallelOneInOneOutContext<'a, S, T, U> where
S: AppendableState<U>,
T: Data + for<'b> Deserialize<'b>,
pub fn new(
timestamp: Timestamp,
config: OperatorConfig,
state: &'a S,
write_stream: WriteStream<T>
) -> Self
sourcepub fn operator_config(&self) -> &OperatorConfig
pub fn operator_config(&self) -> &OperatorConfig
Get the configuration of the operator.
sourcepub fn write_stream(&mut self) -> &mut WriteStream<T>
pub fn write_stream(&mut self) -> &mut WriteStream<T>
Get the write stream to send the output on.
Auto Trait Implementations
impl<'a, S, T, U> !RefUnwindSafe for ParallelOneInOneOutContext<'a, S, T, U>
impl<'a, S, T, U> Send for ParallelOneInOneOutContext<'a, S, T, U> where
U: Send,
impl<'a, S, T, U> Sync for ParallelOneInOneOutContext<'a, S, T, U> where
U: Sync,
impl<'a, S, T, U> Unpin for ParallelOneInOneOutContext<'a, S, T, U> where
U: Unpin,
impl<'a, S, T, U> !UnwindSafe for ParallelOneInOneOutContext<'a, S, T, U>
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>
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