Uses of Interface
org.voltdb.stream.api.pipeline.VoltFunction

Packages that use VoltFunction

Package	Description
org.voltdb.stream.api.pipeline
org.voltdb.stream.function

Uses of VoltFunction in org.voltdb.stream.api.pipeline

Methods in org.voltdb.stream.api.pipeline with parameters of type VoltFunction

Modifier and Type	Method	Description
<O> VoltOpenStreamBuilder<O>	VoltOpenStreamBuilder.processWith(VoltFunction<I,O> processor)

Uses of VoltFunction in org.voltdb.stream.function

Classes in org.voltdb.stream.function that implement VoltFunction

Modifier and Type	Class	Description
class	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.
class	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.