DoMapLogItemsFn runs the MapLogItemsFn on each element of msgs.

DoMapMapLeafFn runs MapMapLeafFn on each MapLeaf.

DoMapMetaFn runs MapMetaFn on meta and collects the outputs.

DoMarshalIndexedValues executes Marshal on each IndexedValue If marshal fails, it will emit an error and continue with a subset of ivs.

DoReadFn runs ReadSliceFn on every source slice and collects the outputs.

DoReduceFn takes the set of mutations and applies them to given leaves.

Join pairs up MapLeaves and IndexedValue by index.

Joined is the result of a CoGroupByKey on []*MapLeaf and []*IndexedValue.

IncMetricFn increments a metric.

MapLogItemFn takes a log item and emits 0 or more KV<index, mutations> pairs.

MapMapLeafFn converts an update into an IndexedValue.

MapMetaFn emits a source slice for every map slice.

ReadSliceFn emits the log messages referenced by slice.

ReduceMutationFn takes all the mutations for an index and an auxiliary input of existing mapleaf(s) and emits a new value for the index.