Trait rlink::api::operator::TStreamOperator

pub trait TStreamOperator: Debug {
    fn operator_name(&self) -> &str;
    fn parallelism(&self) -> u16;
    fn fn_creator(&self) -> FunctionCreator;
}

Required methods

fn operator_name(&self) -> &str

fn parallelism(&self) -> u16

fn fn_creator(&self) -> FunctionCreator

Loading content...

Implementors

impl<T: ?Sized> TStreamOperator for DefaultStreamOperator<T> where
    T: NamedFunction, 

fn operator_name(&self) -> &str

fn parallelism(&self) -> u16

fn fn_creator(&self) -> FunctionCreator

Loading content...