Function polars_core::utils::parallel_op_series
source · [−]pub fn parallel_op_series<F>(
f: F,
s: Series,
n_threads: Option<usize>
) -> Result<Series> where
F: Fn(Series) -> Result<Series> + Send + Sync,
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.