pub struct ParallelPipeline { /* private fields */ }Expand description
Parallel execution pipeline.
Distributes work across multiple threads using morsel-driven scheduling.
Implementations§
Source§impl ParallelPipeline
impl ParallelPipeline
Sourcepub fn new(
source: Arc<dyn ParallelSource>,
operator_factory: Arc<dyn OperatorChainFactory>,
config: ParallelPipelineConfig,
) -> Self
pub fn new( source: Arc<dyn ParallelSource>, operator_factory: Arc<dyn OperatorChainFactory>, config: ParallelPipelineConfig, ) -> Self
Creates a new parallel pipeline.
Sourcepub fn simple(
source: Arc<dyn ParallelSource>,
operator_factory: Arc<dyn OperatorChainFactory>,
) -> Self
pub fn simple( source: Arc<dyn ParallelSource>, operator_factory: Arc<dyn OperatorChainFactory>, ) -> Self
Creates a simple parallel pipeline with default config.
Sourcepub fn execute(&self) -> Result<ParallelPipelineResult, OperatorError>
pub fn execute(&self) -> Result<ParallelPipelineResult, OperatorError>
Executes the pipeline and returns results.
Auto Trait Implementations§
impl Freeze for ParallelPipeline
impl !RefUnwindSafe for ParallelPipeline
impl Send for ParallelPipeline
impl Sync for ParallelPipeline
impl Unpin for ParallelPipeline
impl !UnwindSafe for ParallelPipeline
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more