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:

DefaultGridProjection

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

Base implementation of a GridProjection.

Author:

Janne Valkealahti

Field Summary

Fields inherited from interface org.springframework.yarn.am.grid.GridProjection

PRIORITY_COMPARATOR

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
abstract boolean	acceptMember(GridMember member) Asks a projection if it accepted a member.
protected boolean	addAnyMember(GridMember member) Adds the member to a any tracking list.
protected void	addHostCountMember(java.lang.String host, GridMember member) Adds the host count member.
protected boolean	addHostMember(GridMember member) Adds the member to a host tracking list.
protected void	addRackCountMember(java.lang.String rack, GridMember member) Adds the rack count member.
protected boolean	addRackMember(GridMember member) Adds the member to a rack tracking list.
protected boolean	canFit(GridMember member) Checks if a member can be fit in this projection.
protected int	getAnyCount() Gets the any count.
protected java.util.Collection<GridMember>	getAnyCountMembers() Gets the any count members.
org.apache.hadoop.conf.Configuration	getConfiguration() Gets the hadoop configuration.
protected int	getHostCount(java.lang.String host) Gets a count of hosts tracked by host.
protected java.util.Set<java.lang.String>	getHostCountHosts() Gets the host count hosts.
protected java.util.Collection<GridMember>	getHostCountMembers(java.lang.String host) Gets the host count members.
java.util.Collection<GridMember>	getMembers() Gets the members of this projection as Collection.
java.lang.Integer	getMemory() Gets the memory.
java.lang.Integer	getPriority() Gets the priority.
ProjectionData	getProjectionData() Gets the projection data.
protected int	getRackCount(java.lang.String rack) Gets a count of racks tracked by rack.
protected java.util.Set<java.lang.String>	getRackCountHosts() Gets the rack count hosts.
protected java.util.Collection<GridMember>	getRackCountMembers(java.lang.String rack) Gets the rack count members.
abstract SatisfyStateData	getSatisfyState() Gets the satisfy state.
java.lang.Integer	getVirtualCores() Gets the virtual cores.
GridMember	removeMember(GridMember member) Removes the member.
void	setConfiguration(org.apache.hadoop.conf.Configuration configuration) Sets the hadoop configuration.
void	setMemory(java.lang.Integer memory) Sets the memory.
void	setPriority(java.lang.Integer priority) Sets the priority.
void	setProjectionData(ProjectionData data) Sets the projection data.
void	setVirtualCores(java.lang.Integer virtualCores) Sets the virtual cores.

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)

Instantiates a new abstract grid projection.

Parameters:

configuration - the hadoop 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

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

acceptMember

public abstract boolean acceptMember(GridMember member)

Description copied from interface: GridProjection

Asks a projection if it accepted a member.

Specified by:

acceptMember in interface GridProjection

Parameters:

member - the grid member

Returns:

true, if member accepted by projection

getSatisfyState

public abstract SatisfyStateData getSatisfyState()

Description copied from interface: GridProjection

Gets the satisfy state.

Specified by:

getSatisfyState in interface GridProjection

Returns:

the satisfy state

getPriority

public java.lang.Integer getPriority()

Gets the priority.

Specified by:

getPriority in interface GridProjection

Returns:

the priority

setPriority

public void setPriority(java.lang.Integer priority)

Sets the priority.

Parameters:

priority - the new priority

setVirtualCores

public void setVirtualCores(java.lang.Integer virtualCores)

Sets the virtual cores.

Parameters:

virtualCores - the new virtual cores

getVirtualCores

public java.lang.Integer getVirtualCores()

Gets the virtual cores.

Returns:

the virtual cores

setMemory

public void setMemory(java.lang.Integer memory)

Sets the memory.

Parameters:

memory - the new memory

getMemory

public java.lang.Integer getMemory()

Gets the memory.

Returns:

the memory

addHostMember

protected boolean addHostMember(GridMember member)

Adds the member to a host tracking list.

Parameters:

member - the grid member

Returns:

true, if member were added

addRackMember

protected boolean addRackMember(GridMember member)

Adds the member to a rack tracking list.

Parameters:

member - the grid member

Returns:

true, if member were added

addAnyMember

protected boolean addAnyMember(GridMember member)

Adds the member to a any tracking list.

Parameters:

member - the grid member

Returns:

true, if member were added

getHostCount

protected int getHostCount(java.lang.String host)

Gets a count of hosts tracked by host.

Parameters:

host - the host

Returns:

the host count

getRackCount

protected int getRackCount(java.lang.String rack)

Gets a count of racks tracked by rack.

Parameters:

rack - the rack

Returns:

the rack count

getAnyCount

protected int getAnyCount()

Gets the any count.

Returns:

the any count

getHostCountMembers

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

Gets the host count members.

Parameters:

host - the host

Returns:

the host count members

addHostCountMember

protected void addHostCountMember(java.lang.String host,
                      GridMember member)

Adds the host count member.

Parameters:

host - the host

member - the grid member

addRackCountMember

protected void addRackCountMember(java.lang.String rack,
                      GridMember member)

Adds the rack count member.

Parameters:

rack - the rack

member - the grid member

getRackCountMembers

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

Gets the rack count members.

Parameters:

rack - the rack

Returns:

the rack count members

getAnyCountMembers

protected java.util.Collection<GridMember> getAnyCountMembers()

Gets the any count members.

Returns:

the any count members

getHostCountHosts

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

Gets the host count hosts.

Returns:

the host count hosts

getRackCountHosts

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

Gets the rack count hosts.

Returns:

the rack count hosts

setConfiguration

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

Sets the hadoop configuration.

Parameters:

configuration - the new hadoop configuration

getConfiguration

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

Gets the hadoop configuration.

Returns:

the hadoop configuration

canFit

protected boolean canFit(GridMember member)

Checks if a member can be fit in this projection.

Parameters:

member - the grid member

Returns:

true, if member can be fit