Struct HybridParallelismProfile 

pub struct HybridParallelismProfile { /* private fields */ }

Parallelism configuration

Implementations

impl HybridParallelismProfile

pub fn with_strategy( strategy: Strategy, max_segment_size: u32, config: Option<ParallelismConfig>, ) -> Result<Self, StreamError>

pub fn from_stream_header( header: HeaderV1, config: Option<ParallelismConfig>, ) -> Result<Self, StreamError>

pub fn cpu_workers(&self) -> usize

Read-only accessors

pub fn gpu_workers(&self) -> usize

pub fn inflight_segments(&self) -> usize

pub fn gpu_threshold(&self) -> usize

pub fn gpu(&self) -> Option<GpuInfo>

pub fn single_threaded() -> Self

pub fn semi_dynamic( max_segment_size: u32, mem_fraction: f64, hard_cap: usize, ) -> Self

pub fn dynamic(max_segment_size: u32) -> Self

Trait Implementations

impl Clone for HybridParallelismProfile

fn clone(&self) -> HybridParallelismProfile

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HybridParallelismProfile

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

Formats the value using the given formatter.