Package org.voltdb.stream.api.pipeline

Interface ExceptionHandler

public interface ExceptionHandler

Stream's global exception handler.

Method Summary

Modifier and Type	Method	Description
void	handle(List<?> records, ExecutionContext context, Throwable throwable)	Gets affected messages (records) and exception.

Method Details

handle

void handle(List<?> records,
 ExecutionContext context,
 Throwable throwable)

Gets affected messages (records) and exception. The affected messages can be ExecutionContext.StreamExecutionContext.emit(String, Object) to a named sink.

A handler can define additional sinks to route affected messages on stream failure. Mind that those additional sinks should be always available and should not fail, otherwise framework cannot guarantee data consistency and will crash to prevent no further data lose. See ExceptionHandlerBuilder.addNamedSink(String, VoltStreamSink).

Parameters:

records - affected records by the exception

context - runtime context

throwable - the exception