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
java.lang.String	id
MetricsRegistry	metricsRegistry
java.util.Collection<TaskName>	taskNames

Constructor Summary

Constructors

Constructor and Description
SamzaContainerContext(java.lang.String id, Config config, java.util.Collection<TaskName> taskNames, MetricsRegistry metricsRegistry) 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 java.lang.String id

config

public final Config config

taskNames

public final java.util.Collection<TaskName> taskNames

metricsRegistry

public final MetricsRegistry metricsRegistry

Constructor Detail

SamzaContainerContext

public SamzaContainerContext(java.lang.String id,
                             Config config,
                             java.util.Collection<TaskName> taskNames,
                             MetricsRegistry metricsRegistry)

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.

metricsRegistry - the MetricsRegistry for the container metrics