Struct StreamEnv 

pub struct StreamEnv {
    pub chain_job: Arc<Mutex<Option<ChainJob>>>,
    /* private fields */
}

Job environment: DSL chain construction panics on programmer errors. Runtime entry: crate::stream::chain_execute::execute.

Fields

chain_job: Arc<Mutex<Option<ChainJob>>>

Implementations

impl StreamEnv

pub fn new() -> Self

pub fn set_state_work_dir(&mut self, path: impl Into<PathBuf>)

pub fn set_enable_chain_state(&mut self, enable: bool)

Enable per-subtask chain_state (chains/{subtask}/chain.db) at task spawn.

pub fn add_initial_job_state(&self, namespace: &str, key: &str, value: &[u8])

Buffer an initial job-state entry that will be flushed into job_state before the stream starts.

pub fn set_parallelism(&mut self, p: usize)

pub fn set_checkpoint_interval(&mut self, ms: u64)

pub async fn execute(self) -> StreamResult<()>

Run the built chain until Ctrl+C, task failure, or checkpoint manager exit.

pub fn add_source<T: Send + 'static, S: SourceFunction<T> + Clone + Send + 'static>( &self, source: S, ) -> DataStream<T>

pub fn add_source_with_factory<T: Send + 'static, S: SourceFunction<T> + Send + 'static>( &self, factory: impl Fn() -> S + Send + 'static, ) -> DataStream<T>

Trait Implementations

impl Clone for StreamEnv

fn clone(&self) -> StreamEnv

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for StreamEnv

fn default() -> Self

Returns the “default value” for a type.