Spring for Apache Hadoop

org.springframework.yarn.am.assign
Class DefaultContainerAssign

java.lang.Object
  extended by org.springframework.yarn.am.assign.DefaultContainerAssign
All Implemented Interfaces:
ContainerAssign<java.lang.Object>

public class DefaultContainerAssign
extends java.lang.Object
implements ContainerAssign<java.lang.Object>

Default ContainerAssign implementation using Objects as assigned data.

Author:
Janne Valkealahti

Constructor Summary
DefaultContainerAssign()
           
 
Method Summary
 void assign(org.apache.hadoop.yarn.api.records.ContainerId containerId, java.lang.Object data)
          Assign data with container.
 org.apache.hadoop.yarn.api.records.ContainerId getAssignedContainer(java.lang.Object data)
          Gets the assigned container.
 java.lang.Object getAssignedData(org.apache.hadoop.yarn.api.records.ContainerId containerId)
          Gets the assigned data.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultContainerAssign

public DefaultContainerAssign()
Method Detail

assign

public void assign(org.apache.hadoop.yarn.api.records.ContainerId containerId,
                   java.lang.Object data)
Description copied from interface: ContainerAssign
Assign data with container.

Specified by:
assign in interface ContainerAssign<java.lang.Object>
Parameters:
containerId - the container id
data - the data

getAssignedData

public java.lang.Object getAssignedData(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Description copied from interface: ContainerAssign
Gets the assigned data.

Specified by:
getAssignedData in interface ContainerAssign<java.lang.Object>
Parameters:
containerId - the container id
Returns:
the assigned data

getAssignedContainer

public org.apache.hadoop.yarn.api.records.ContainerId getAssignedContainer(java.lang.Object data)
Description copied from interface: ContainerAssign
Gets the assigned container.

Specified by:
getAssignedContainer in interface ContainerAssign<java.lang.Object>
Parameters:
data - the data
Returns:
the assigned container

Spring for Apache Hadoop