Trait rlink::api::env::StreamApp[−][src]

pub trait StreamApp: Send + Sync + Clone {
    fn prepare_properties(&self, properties: &mut Properties);
    fn build_stream(
        &self, 
        properties: &Properties, 
        env: &mut StreamExecutionEnvironment
    );
}

define a stream application

Required methods

`fn prepare_properties(&self, properties: &mut Properties)`[src]

prepare job properties, only invoke once on the Coordinator, All initialization operations should be handled in this method.

`fn build_stream( &self, properties: &Properties, env: &mut StreamExecutionEnvironment )`[src]

build application stream, will invoke multiple times on the Coordinator and Worker, ensure the method is stateless.

Loading content...

Implementors

Loading content...