graphed_histogram¶
Deferred boost-histogram/hist filling for graphed: a fill records, a runner computes.
The dask-histogram analogue, with graphed’s own evaluation idiom. .fill(...) records a step
the runner performs later, identified by the content hash of a canonical axes/storage
description — so identical fills collapse to one, and nothing in graphed or in any array backend
needs an opinion about histograms. plan() exports the plan any runner aggregates, one fill
task per chunk combined by add_histograms(). session.materialize(node) evaluates a single
fill on the spot, for a source that has no chunks to hand out.
Functions
- graphed_histogram.evaluators(*histograms)[source]¶
Merged
{content hash: evaluator}registry, for wiring these fills into a graph you evaluate yourself.- Parameters:
histograms (Histogram)
- Return type:
dict[str, Callable[[…], object]]
- graphed_histogram.spec_of(hist)[source]¶
The canonical spec string of a (deferred or eager) boost histogram.
- Parameters:
hist (object)
- Return type:
str
Modules
The deferred |