org.apache.samza.task

Interface TaskCallback

public interface TaskCallback

A TaskCallback is fired by a AsyncStreamTask to notify when an asynchronous process has completed. If the callback is fired multiple times, it will throw IllegalStateException.

Method Summary

Modifier and Type	Method and Description
void	complete() Invoke when the asynchronous process completed with success.
void	failure(java.lang.Throwable t) Invoke when the asynchronous process failed with an error.

Method Detail

complete

void complete()

Invoke when the asynchronous process completed with success.

failure

void failure(java.lang.Throwable t)

Invoke when the asynchronous process failed with an error.

Parameters:

t - error throwable