org.apache.samza.operators

Interface ContextManager

@InterfaceStability.Unstable
public interface ContextManager

Manages custom context that is shared across multiple operator functions in a task.

Method Summary

Modifier and Type	Method and Description
void	close() Allows closing the custom context that is shared across multiple operator functions in a task.
void	init(Config config, TaskContext context) Allows initializing and setting a custom context that is shared across multiple operator functions in a task.

Method Detail

init

void init(Config config,
          TaskContext context)

Allows initializing and setting a custom context that is shared across multiple operator functions in a task.

This method is invoked before any InitableFunctions are initialized. Use TaskContext.setUserContext(Object) to set the context here and TaskContext.getUserContext() to get it in InitableFunctions.

Parameters:

config - the Config for the application

context - the TaskContext for this task

close

void close()

Allows closing the custom context that is shared across multiple operator functions in a task.