Struct StreamPipeline 

pub struct StreamPipeline { /* private fields */ }

A configured stream processing pipeline

This represents a fully configured pipeline that can be used to create executors and add operators.

Implementations

impl StreamPipeline

pub fn config(&self) -> &PipelineConfig

Get the pipeline configuration

pub fn name(&self) -> &str

Get the pipeline name

pub fn description(&self) -> Option<&str>

Get the pipeline description

pub fn tags(&self) -> &[String]

Get the pipeline tags

pub fn add_operator<O: StreamOperator + 'static>(&mut self, operator: O)

Add an operator to the pipeline

Example

let mut pipeline = StreamPipelineBuilder::new().build()?;

// Add a map operator
// let operator = MapOperator::new(|x| x * 2);
// pipeline.add_operator(operator);

pub fn operators(&self) -> &[Arc<dyn StreamOperator>]

Get all operators in the pipeline

pub fn create_executor<T>(&self) -> StreamExecutor<T>

where T: Clone + Send + Sync + 'static + Serialize + for<'de> Deserialize<'de>,

Create an executor for this pipeline

Example

let pipeline = StreamPipelineBuilder::new()
    .with_name("test-pipeline")
    .build()?;

let executor = pipeline.create_executor();
// executor.run().await?;

Trait Implementations

impl Clone for StreamPipeline

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamPipeline

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.