Trait AssignTimestamps 

pub trait AssignTimestamps<K, V, T>: Sealed {
    // Required method
    fn assign_timestamps<TO: Timestamp>(
        self,
        name: &str,
        assigner: impl FnMut(&DataMessage<K, V, T>) -> TO + 'static,
    ) -> NeedsEpochs<K, V, TO>;
}

Assign timestamps to stream messages

Required Methods

fn assign_timestamps<TO: Timestamp>( self, name: &str, assigner: impl FnMut(&DataMessage<K, V, T>) -> TO + 'static, ) -> NeedsEpochs<K, V, TO>

Assigns a new timestamp to every message. NOTE: Any Epochs arriving at this operator are dropped with the exception of the MAX epoch. See Timestamp::MAX

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<K, V, T> AssignTimestamps<K, V, T> for StreamBuilder<K, V, T>

where K: MaybeKey, V: Data, T: Timestamp,