MCPcopy Create free account
hub / github.com/dask/dask / nancumprod

Function nancumprod

dask/array/reductions.py:243–265  ·  view source on GitHub ↗

Dask added an additional keyword-only argument ``method``. method : {'sequential', 'blelloch'}, optional Choose which method to use to perform the cumprod. Default is 'sequential'. * 'sequential' performs the cumprod of each prior block before the current block. * 'ble

(x, axis, dtype=None, out=None, *, method="sequential")

Source from the content-addressed store, hash-verified

241
242@derived_from(np)
243def nancumprod(x, axis, dtype=None, out=None, *, method="sequential"):
244 """Dask added an additional keyword-only argument ``method``.
245
246 method : {'sequential', 'blelloch'}, optional
247 Choose which method to use to perform the cumprod. Default is 'sequential'.
248
249 * 'sequential' performs the cumprod of each prior block before the current block.
250 * 'blelloch' is a work-efficient parallel cumprod. It exposes parallelism by first
251 taking the product of each block and combines the products via a binary tree.
252 This method may be faster or more memory efficient depending on workload,
253 scheduler, and hardware. More benchmarking is necessary.
254 """
255 return cumreduction(
256 chunk.nancumprod,
257 operator.mul,
258 1,
259 x,
260 axis,
261 dtype,
262 out=out,
263 method=method,
264 preop=np.nanprod,
265 )
266
267
268@derived_from(np)

Callers

nothing calls this directly

Calls 1

cumreductionFunction · 0.85

Tested by

no test coverage detected