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(Config config, TaskContext context) Called by TaskRunner each time an implementing task is created.

Method Detail

init

void init(Config config,
          TaskContext context)
   throws java.lang.Exception

Called by TaskRunner each time an implementing task is created.

Parameters:

config - Allows accessing of fields in the configuration files that this StreamTask is specified in.

context - Allows accessing of contextual data of this StreamTask.

Throws:

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