org.springframework.yarn.am.grid.support

Class AbstractGridProjection

java.lang.Object

org.springframework.yarn.am.grid.support.AbstractGridProjection

All Implemented Interfaces:

GridProjection

Direct Known Subclasses:

AnyGridProjection, HostsGridProjection, RacksGridProjection

public abstract class AbstractGridProjection
extends java.lang.Object
implements GridProjection

Base implementation of a GridProjection.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
AbstractGridProjection() Instantiates a new abstract grid projection.
AbstractGridProjection(org.apache.hadoop.conf.Configuration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
abstract boolean	acceptMember(GridMember member)
protected boolean	addMember(GridMember member)
org.apache.hadoop.conf.Configuration	getConfiguration()
protected int	getHostCount(java.lang.String host)
protected java.util.Set<java.lang.String>	getHostCountHosts()
protected java.util.Collection<GridMember>	getHostCountMembers(java.lang.String host)
java.util.Collection<GridMember>	getMembers() Gets the members of this projection as Collection.
java.lang.Integer	getPriority()
ProjectionData	getProjectionData() Gets the projection data.
protected int	getRackCount(java.lang.String rack)
protected java.util.Set<java.lang.String>	getRackCountHosts()
protected java.util.Collection<GridMember>	getRackCountMembers(java.lang.String host)
abstract SatisfyStateData	getSatisfyState() Gets the satisfy state.
protected boolean	isSamePriority(GridMember member)
GridMember	removeMember(GridMember member) Removes the member.
void	setConfiguration(org.apache.hadoop.conf.Configuration configuration)
void	setPriority(java.lang.Integer priority)
void	setProjectionData(ProjectionData data) Sets the projection data.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractGridProjection

public AbstractGridProjection()

Instantiates a new abstract grid projection.

AbstractGridProjection

public AbstractGridProjection(org.apache.hadoop.conf.Configuration configuration)

Method Detail

getMembers

public java.util.Collection<GridMember> getMembers()

Description copied from interface: GridProjection

Gets the members of this projection as Collection.

Specified by:

getMembers in interface GridProjection

Returns:

the projection members

setProjectionData

public void setProjectionData(ProjectionData data)

Description copied from interface: GridProjection

Sets the projection data.

Specified by:

setProjectionData in interface GridProjection

Parameters:

data - the new projection data

getProjectionData

public ProjectionData getProjectionData()

Description copied from interface: GridProjection

Gets the projection data.

Specified by:

getProjectionData in interface GridProjection

Returns:

the projection data

acceptMember

public abstract boolean acceptMember(GridMember member)

Specified by:

acceptMember in interface GridProjection

getSatisfyState

public abstract SatisfyStateData getSatisfyState()

Description copied from interface: GridProjection

Gets the satisfy state.

Specified by:

getSatisfyState in interface GridProjection

Returns:

the satisfy state

setPriority

public void setPriority(java.lang.Integer priority)

getPriority

public java.lang.Integer getPriority()

addMember

protected boolean addMember(GridMember member)

removeMember

public GridMember removeMember(GridMember member)

Description copied from interface: GridProjection

Removes the member.

Specified by:

removeMember in interface GridProjection

Parameters:

member - the member

Returns:

the grid member

getHostCount

protected int getHostCount(java.lang.String host)

getRackCount

protected int getRackCount(java.lang.String rack)

getHostCountMembers

protected java.util.Collection<GridMember> getHostCountMembers(java.lang.String host)

getRackCountMembers

protected java.util.Collection<GridMember> getRackCountMembers(java.lang.String host)

getHostCountHosts

protected java.util.Set<java.lang.String> getHostCountHosts()

getRackCountHosts

protected java.util.Set<java.lang.String> getRackCountHosts()

setConfiguration

public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

isSamePriority

protected boolean isSamePriority(GridMember member)