Uses of Interface
org.voltdb.stream.api.pipeline.VoltLifecycle
Package
Description
-
Uses of VoltLifecycle in org.voltdb.stream.api.extension
Modifier and TypeInterfaceDescriptioninterface
this is a most basic building block of the stream.interface
interface
interface
this interface is a 1-1 copy ofVoltStreamSource
but it drops generics. -
Uses of VoltLifecycle in org.voltdb.stream.api.pipeline
Modifier and TypeInterfaceDescriptioninterface
VoltFunction<I,
O> This class represents a simple transformation between input event and output message.interface
This class encapsulates any integration logic with a downstream system.interface
This class encapsulates any integration logic with an upstream system. -
Uses of VoltLifecycle in org.voltdb.stream.function
Modifier and TypeClassDescriptionclass
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 givenaccumulatorFunction
, and cancels the execution once the accumulated value exceeds given threshold. -
Uses of VoltLifecycle in org.voltdb.stream.sink
Modifier and TypeClassDescriptionclass
FileSink<T>
A sink that writes streamed data items to a file within a specified directory.class
IterableSink<T>
Captures all stream items into a list.class
StdoutSink<T>
A sink that writes streamed data items to the standard output (console). -
Uses of VoltLifecycle in org.voltdb.stream.source
Modifier and TypeClassDescriptionclass
Base class for simple sources that generate elements algorithmically.class
Generates a stream of data items from anIterable
.