@@ -38,6 +38,7 @@ def histogram(
38
38
histogram : Any | None = None ,
39
39
storage : bh .storage .Storage = bh .storage .Double (),
40
40
threads : int | None = None ,
41
+ split_every : int | None = None ,
41
42
) -> AggHistogram | tuple [da .Array , ...] | tuple [da .Array , list [da .Array ]]:
42
43
"""Histogram Dask data in one dimension.
43
44
@@ -121,6 +122,7 @@ def histogram(
121
122
histogram = True ,
122
123
storage = storage ,
123
124
threads = threads ,
125
+ split_every = split_every ,
124
126
)
125
127
if histogram is None :
126
128
return h .to_dask_array (flow = False , dd = False ) # type: ignore
@@ -139,6 +141,7 @@ def histogram2d(
139
141
histogram : Any | None = None ,
140
142
storage : bh .storage .Storage = bh .storage .Double (),
141
143
threads : int | None = None ,
144
+ split_every : int | None = None ,
142
145
) -> AggHistogram | tuple [da .Array , ...]:
143
146
"""Histogram Dask data in two dimensions.
144
147
@@ -244,6 +247,7 @@ def histogram2d(
244
247
histogram = True ,
245
248
storage = storage ,
246
249
threads = threads ,
250
+ split_every = split_every ,
247
251
)
248
252
if histogram is None :
249
253
return h .to_dask_array (flow = False , dd = False ) # type: ignore
@@ -261,6 +265,7 @@ def histogramdd(
261
265
histogram : Any | None = None ,
262
266
storage : bh .storage .Storage = bh .storage .Double (),
263
267
threads : int | None = None ,
268
+ split_every : int | None = None ,
264
269
) -> AggHistogram | tuple [da .Array , list [da .Array ]]:
265
270
"""Histogram Dask data in multiple dimensions.
266
271
@@ -446,7 +451,13 @@ def histogramdd(
446
451
axes .append (bh .axis .Regular (bins = b , start = r [0 ], stop = r [1 ])) # type: ignore
447
452
448
453
# Finally create the histogram object.
449
- ah = factory (* a , axes = axes , storage = storage , weights = weights )
454
+ ah = factory (
455
+ * a ,
456
+ axes = axes ,
457
+ storage = storage ,
458
+ weights = weights ,
459
+ split_every = split_every ,
460
+ )
450
461
451
462
if histogram is not None :
452
463
return ah # type: ignore
0 commit comments