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

Packages that use ExecutionContext

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 ExecutionContext in org.voltdb.stream.api.extension

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

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

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

Methods in org.voltdb.stream.api.pipeline that return ExecutionContext

Modifier and Type	Method	Description
ExecutionContext	VoltStreamBuilder.getExecutionContext()

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

Modifier and Type	Method	Description
default CommitResult	VoltStreamSink.commit(ExecutionContext context)	the callback is invoked when the sink has to perform any logic assuring data is securely passed to downstream system
default CommitResult	VoltStreamSource.commit(long batchId, ExecutionContext context)	the callback is invoked when the source has to perform any logic assuring data has been successfully processed and upstream system can make progress.
default void	VoltLifecycle.configure(ExecutionContext context)
default void	VoltLifecycle.destroy(ExecutionContext context)
void	ExceptionHandler.handle(List<?> records, ExecutionContext context, Throwable throwable)	Gets affected messages (records) and exception.
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 ExecutionContext in org.voltdb.stream.function

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

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

Uses of ExecutionContext in org.voltdb.stream.sink

Methods in org.voltdb.stream.sink with parameters of type ExecutionContext

Modifier and Type	Method	Description
CommitResult	FileSink.commit(ExecutionContext context)
CommitResult	StdoutSink.commit(ExecutionContext context)
void	FileSink.configure(ExecutionContext context)

Uses of ExecutionContext in org.voltdb.stream.source

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

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