Skip to main content

ReducerOps

arcon_state::backend::ops

Trait ReducerOps 

Source 
pub trait ReducerOps {
    // Required methods
    fn reducer_clear<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>(
        &self,
        handle: &Handle<ReducerState<T, F>, IK, N>,
    ) -> Result<()>;
    fn reducer_get<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>(
        &self,
        handle: &Handle<ReducerState<T, F>, IK, N>,
    ) -> Result<Option<T>>;
    fn reducer_reduce<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>(
        &self,
        handle: &Handle<ReducerState<T, F>, IK, N>,
        value: T,
    ) -> Result<()>;
}

Required Methods§

Source

fn reducer_clear<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>( &self, handle: &Handle<ReducerState<T, F>, IK, N>, ) -> Result<()>

Source

fn reducer_get<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>( &self, handle: &Handle<ReducerState<T, F>, IK, N>, ) -> Result<Option<T>>

Source

fn reducer_reduce<T: Value, F: Reducer<T>, IK: Metakey, N: Metakey>( &self, handle: &Handle<ReducerState<T, F>, IK, N>, value: T, ) -> Result<()>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§