Trait MergeableOperator 

pub trait MergeableOperator: Send + Sync {
    // Required method
    fn merge_from(&mut self, other: Self)
       where Self: Sized;

    // Provided method
    fn supports_parallel_merge(&self) -> bool { ... }
}

Trait for operators that support parallel merge.

Pipeline breakers must implement this to enable parallel execution.

Required Methods

fn merge_from(&mut self, other: Self)

where Self: Sized,

Merges partial results from another operator instance.

Provided Methods

fn supports_parallel_merge(&self) -> bool

Returns whether this operator supports parallel merge.

Implementors