Package org.voltdb.stream.api.extension

Interface StreamSink

All Superinterfaces:

Operator, VoltLifecycle

public interface StreamSink
extends 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 CommitResult	commit(long batchId, ExecutionContext context)
void	consume(Object output, ExecutionContext context)
default Operator.Type	getType()
default void	nextBatchStarts(long batchId)

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

configure, destroy

Method Details

consume

void consume(Object output,
 ExecutionContext context)

nextBatchStarts

default void nextBatchStarts(long batchId)

batchProcessed

default void batchProcessed(long batchId)

commit

default CommitResult commit(long batchId,
 ExecutionContext context)

getType

default Operator.Type getType()

Specified by:

getType in interface Operator