Package org.voltdb.stream.api.extension

Interface StreamFunction

All Superinterfaces:

Operator, VoltLifecycle

public interface StreamFunction
extends VoltLifecycle, Operator

Nested Class Summary

Nested classes/interfaces inherited from interface org.voltdb.stream.api.extension.Operator

Operator.Type

Method Summary

Modifier and Type	Method	Description
default void	batchProcessed(long batchId)
default Operator.Type	getType()
default void	initialize(Consumer<Object> consumer)
default void	nextBatchStarts(long batchId)
void	process(Object input, Consumer<Object> consumer, ExecutionContext context)

Methods inherited from interface org.voltdb.stream.api.pipeline.VoltLifecycle

configure, destroy

Method Details

process

void process(Object input,
 Consumer<Object> consumer,
 ExecutionContext context)

initialize

default void initialize(Consumer<Object> consumer)

nextBatchStarts

default void nextBatchStarts(long batchId)

batchProcessed

default void batchProcessed(long batchId)

getType

default Operator.Type getType()

Specified by:

getType in interface Operator