ham-fisted.protocols — com.cnuernber/ham-fisted 1.000-beta-35

ParallelReducer clj protocol

Parallel reducers are simple a single object that you can pass into preduce as opposed to 3 separate functions.

->init-val-fn clj

(->init-val-fn item)

Returns the initial values for a parallel reduction. This function takes no arguments and returns the initial accumulator.

->merge-fn clj

(->merge-fn item)

Returns the merge function for a parallel reduction. This function takes two accumulators and returns a or modified accumulator.

->rfn clj

(->rfn item)

Returns the reduction function for a parallel reduction. This function takes two arguments, the accumulator and a value from the collection and returns a new or modified accumulator.

finalize clj

(finalize item v)

A finalize function called on the result of the reduction after it is reduced but before it is returned to the user. Identity is a reasonable default.

ParallelReduction clj protocol

Protocol to define a parallel reduction in a collection-specific pathway. Specializations are in impl as that is where the parallelization routines are found.

preduce clj

(preduce coll init-val-fn rfn merge-fn options)

Container-specific parallelized reduction. Reductions must respect the pool passed in via the options.