Function polars_core::utils::parallel_op_series[][src]

pub fn parallel_op_series<F>(
    f: F,
    s: Series,
    n_threads: Option<usize>
) -> Result<Series> where
    F: Fn(Series) -> Result<Series> + Send + Sync
This is supported on crate feature private only.
Expand description

Simple wrapper to parallelize functions that can be divided over threads aggregated and finally aggregated in the main thread. This can be done for sum, min, max, etc.