Struct CacheSource 

pub struct CacheSource<T, S: CacheReplayer<T>> { /* private fields */ }

Trait Implementations

impl<T: Clone, S: CacheReplayer<T>> Clone for CacheSource<T, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, S: CacheReplayer<T>> Display for CacheSource<T, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Data, S: CacheReplayer<T> + Send> Operator for CacheSource<T, S>

type Out = T

fn setup(&mut self, metadata: &mut ExecutionMetadata<'_>)

Setup the operator chain. This is called before any call to next and it’s used to initialize the operator. When it’s called the operator has already been cloned and it will never be cloned again. Therefore it’s safe to store replica-specific metadata inside of it.

fn next(&mut self) -> StreamElement<T>

Take a value from the previous operator, process it and return it.

fn structure(&self) -> BlockStructure

A more refined representation of the operator and its predecessors.

impl<T: Clone + Send + 'static, S: CacheReplayer<T>> Source for CacheSource<T, S>

fn replication(&self) -> Replication

The maximum parallelism offered by this operator.