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	name
java.util.Collection<Partition>	partitions

Constructor Summary

Constructors

Constructor and Description
SamzaContainerContext(java.lang.String name, Config config, java.util.Collection<Partition> partitions) 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

name

public final java.lang.String name

config

public final Config config

partitions

public final java.util.Collection<Partition> partitions

Constructor Detail

SamzaContainerContext

public SamzaContainerContext(java.lang.String name,
                     Config config,
                     java.util.Collection<Partition> partitions)

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

Parameters:

name - The name of the container (either a YARN AM or SamzaContainer).

config - The job configuration.

partitions - The set of input partitions assigned to this container.