Trait rlink::core::operator::TStreamOperator [−][src]
pub trait TStreamOperator: Debug { fn operator_name(&self) -> &str; fn parallelism(&self) -> u16; fn schema(&self, input_schema: FnSchema) -> FnSchema; fn fn_creator(&self) -> FunctionCreator; }