Package org.voltdb.stream.function

package org.voltdb.stream.function

Classes

Class	Description
BatchAccumulator<I,O>	A processing function that accumulates incoming data items into a single aggregated result and emits the result once a batch is processed.
CancelingFunction<I,O extends Comparable<O>>	This identity function, but it accumulates value with given accumulatorFunction, and cancels the execution once the accumulated value exceeds given threshold.