org.apache.samza.task

Interface InitableTask

public interface InitableTask

Used as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks are instantiated by TaskRunner.

Method Summary

Modifier and Type	Method and Description
void	init(Context context) Called by TaskRunner each time an implementing task is created.

Method Detail

init

void init(Context context)
   throws java.lang.Exception

Called by TaskRunner each time an implementing task is created.

Parameters:

context - Allows accessing of contextual data of this StreamTask.

Throws:

java.lang.Exception - Any exception types encountered during the execution of the processing task.