Trait StatefulOp 

pub trait StatefulOp<K, VI, T>: Sealed {
    // Required method
    fn stateful_op<VO: Data, S: Default + Serialize + DeserializeOwned + 'static>(
        self,
        name: &str,
        logic: impl StatefulLogic<K, VI, T, VO, S>,
    ) -> StreamBuilder<K, VO, T>;
}

Append a stateful operator to the stream

Required Methods

fn stateful_op<VO: Data, S: Default + Serialize + DeserializeOwned + 'static>( self, name: &str, logic: impl StatefulLogic<K, VI, T, VO, S>, ) -> StreamBuilder<K, VO, T>

Append an arbitrary stateful operator to the datastream.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl<K, VI, T> StatefulOp<K, VI, T> for StreamBuilder<K, VI, T>

where K: Key + Serialize + DeserializeOwned, VI: Data + Serialize + DeserializeOwned, T: Timestamp,