org.apache.samza.container

Class SamzaContainerContext

java.lang.Object

org.apache.samza.container.SamzaContainerContext

public class SamzaContainerContext
extends java.lang.Object

A SamzaContainerContext maintains per-container information for the tasks it executes.

Field Summary

Fields

Modifier and Type	Field and Description
Config	config
int	id
java.util.Collection<TaskName>	taskNames

Constructor Summary

Constructors

Constructor and Description
SamzaContainerContext(int id, Config config, java.util.Collection<TaskName> taskNames) An immutable context object that can passed to tasks to give them information about the container in which they are executing.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

id

public final int id

config

public final Config config

taskNames

public final java.util.Collection<TaskName> taskNames

Constructor Detail

SamzaContainerContext

public SamzaContainerContext(int id,
                             Config config,
                             java.util.Collection<TaskName> taskNames)

An immutable context object that can passed to tasks to give them information about the container in which they are executing.

Parameters:

id - The id of the container.

config - The job configuration.

taskNames - The set of taskName keys for which this container is responsible.