Package org.voltdb.stream.api.extension

Interface StreamSource

All Superinterfaces:

Operator, VoltLifecycle

public interface StreamSource
extends Operator

this interface is a 1-1 copy of VoltStreamSource but it drops generics. Generics are useful to show problems with data flow in the pipeline but after that creates lots of problems.

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 CommitResult	commit(long batchId, ExecutionContext context)
default Operator.Type	getType()
void	process(long batchId, Consumer<Object> consumer, ExecutionContext context)

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

configure, destroy

Method Details

process

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

commit

default CommitResult commit(long batchId,
 ExecutionContext context)

getType

default Operator.Type getType()

Specified by:

getType in interface Operator