Struct erdos::dataflow::state::TimeVersionedState

pub struct TimeVersionedState<S> where
    S: 'static + Default + Send + Sync,  { /* private fields */ }

The TimeVersionedState provides a default implementation of the State for a type S. The structure automatically commits the final state for a timestamp into a HashMap and initializes new states for a timestamp t by invoking their default method.

Implementations

impl<S> TimeVersionedState<S> where
    S: 'static + Default + Send + Sync, 

pub fn new() -> Self

Trait Implementations

impl<S> Default for TimeVersionedState<S> where
    S: 'static + Default + Send + Sync, 

fn default() -> Self

Returns the “default value” for a type.

impl<S> State for TimeVersionedState<S> where
    S: 'static + Default + Send + Sync, 

type Item = S

fn commit(&mut self, timestamp: &Timestamp)

The commit method commits the final state for a given timestamp.

fn last_committed_timestamp(&self) -> Timestamp

Retrieves the last committed timestamp by this state. This method can be used in conjunction with Self::at to retrieve the latest committed state.

fn at(&mut self, timestamp: &Timestamp) -> Option<&mut Self::Item>

Retrieve the state at a given timestamp. If the state for that timestamp hasn’t been initialized yet, invoke the default method on the Self::Item type, and return the newly created state for that timestamp.

impl<T, U> TwoInOneOut<TimeVersionedState<(Vec<T, Global>, Vec<U, Global>)>, T, U, (T, U)> for TimestampJoinOperator where
    T: Data + for<'a> Deserialize<'a>,
    U: Data + for<'a> Deserialize<'a>, 

fn on_left_data(
    &mut self,
    ctx: &mut TwoInOneOutContext<'_, TimeVersionedState<(Vec<T>, Vec<U>)>, (T, U)>,
    data: &T
)

fn on_right_data(
    &mut self,
    ctx: &mut TwoInOneOutContext<'_, TimeVersionedState<(Vec<T>, Vec<U>)>, (T, U)>,
    data: &U
)

fn on_watermark(
    &mut self,
    ctx: &mut TwoInOneOutContext<'_, TimeVersionedState<(Vec<T>, Vec<U>)>, (T, U)>
)

fn setup(&mut self, setup_context: &mut SetupContext<S>)

fn run(
    &mut self,
    config: &OperatorConfig,
    left_read_stream: &mut ReadStream<T>,
    right_read_stream: &mut ReadStream<U>,
    write_stream: &mut WriteStream<V>
)

fn destroy(&mut self)