Uses of Interface
org.voltdb.stream.api.Consumer

Packages that use Consumer

Package	Description
org.voltdb.stream.api.extension
org.voltdb.stream.api.pipeline
org.voltdb.stream.function
org.voltdb.stream.sink
org.voltdb.stream.source

Uses of Consumer in org.voltdb.stream.api.extension

Methods in org.voltdb.stream.api.extension with parameters of type Consumer

Modifier and Type	Method	Description
default void	StreamFunction.initialize(Consumer<Object> consumer)
void	StreamFunction.process(Object input, Consumer<Object> consumer, ExecutionContext context)
void	StreamSource.process(long batchId, Consumer<Object> consumer, ExecutionContext context)

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

Subinterfaces of Consumer in org.voltdb.stream.api.pipeline

Modifier and Type	Interface	Description
interface	VoltStreamSink<T>	This class encapsulates any integration logic with a downstream system.

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

Modifier and Type	Method	Description
default void	VoltFunction.initialize(Consumer<O> consumer)	the callback is invoked when the function is created and a consumer is assigned but the function is not yet scheduled to handle any incoming events.
void	VoltFunction.process(I input, Consumer<O> consumer, ExecutionContext context)	processes input and emits output messages to a consumer
void	VoltStreamSource.process(long batchId, Consumer<T> consumer, ExecutionContext context)	Whenever a scheduler has an idle worker it will bind a worker to the source allowing the source to starts processing data.

Uses of Consumer in org.voltdb.stream.function

Methods in org.voltdb.stream.function with parameters of type Consumer

Modifier and Type	Method	Description
void	BatchAccumulator.initialize(Consumer<O> consumer)
void	BatchAccumulator.process(I input, Consumer<O> consumer, ExecutionContext context)
void	CancelingFunction.process(I input, Consumer<I> consumer, ExecutionContext context)

Uses of Consumer in org.voltdb.stream.sink

Classes in org.voltdb.stream.sink that implement Consumer

Modifier and Type	Class	Description
class	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 Consumer in org.voltdb.stream.source

Methods in org.voltdb.stream.source with parameters of type Consumer

Modifier and Type	Method	Description
void	GeneratorSource.process(long batchId, Consumer<T> consumer, ExecutionContext context)