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.