All Classes and Interfaces
Class
Description
A processing function that accumulates incoming data items into a single aggregated result and emits the result once
a batch is processed.
This identity function, but it accumulates value with given
accumulatorFunction, and cancels the execution
once the accumulated value exceeds given threshold.This interface represents results of potentially asynchronous commit action.
Represents configuration part that is obtained from yaml configuration.
A Consumer is a link between upstream and downstream operator.
Stream's global exception handler.
A sink that writes streamed data items to a file within a specified directory.
Base class for simple sources that generate elements algorithmically.
Captures all stream items into a list.
Generates a stream of data items from an
Iterable.this is a most basic building block of the stream.
A sink that writes streamed data items to the standard output (console).
this interface is a 1-1 copy of
VoltStreamSource but it drops generics.Defines execution environment in which stream operates.
This class represents a simple transformation between input event and output message.
Defines life cycle of the operator.
This is entry point for a volt stream definition.
Convenient place to register any source, sink or function custom implementation - see
VoltEnvironment.register(Class, ConfigurableOperatorProducer),
by dividing component into configuration and implementation, the system can bind different implementations for testing and other for production.This class encapsulates any integration logic with a downstream system.
A stream sink configurator.
This class encapsulates any integration logic with an upstream system.
A stream source configurator.