Uses of Interface
org.voltdb.stream.api.extension.CommitResult
Package
Description
-
Uses of CommitResult in org.voltdb.stream.api.extension
Modifier and TypeMethodDescriptiondefault CommitResult
StreamSink.commit
(long batchId, ExecutionContext context) default CommitResult
StreamSource.commit
(long batchId, ExecutionContext context) static CommitResult
CommitResult.fromException
(Throwable e) Modifier and TypeMethodDescriptionvoid
CommitResult.AsynchronousResultHandler.handleResult
(CommitResult result) -
Uses of CommitResult in org.voltdb.stream.api.pipeline
Modifier and TypeMethodDescriptiondefault CommitResult
VoltStreamSink.commit
(ExecutionContext context) the callback is invoked when the sink has to perform any logic assuring data is securely passed to downstream systemdefault 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. -
Uses of CommitResult in org.voltdb.stream.sink
Modifier and TypeMethodDescriptionFileSink.commit
(ExecutionContext context) StdoutSink.commit
(ExecutionContext context)