org.apache.storm.scheduler.resource

Class User

java.lang.Object

org.apache.storm.scheduler.resource.User

public class User
extends Object

Constructor Summary

Constructors

Constructor and Description
User(String userId)
User(String userId, Map<String,Double> resourcePool)
User(User src) Copy Constructor

Method Summary

Modifier and Type	Method and Description
void	addTopologyToAttemptedQueue(TopologyDetails topo)
void	addTopologyToInvalidQueue(TopologyDetails topo)
void	addTopologyToPendingQueue(TopologyDetails topo)
void	addTopologyToPendingQueue(TopologyDetails topo, Cluster cluster)
void	addTopologyToRunningQueue(TopologyDetails topo)
void	addTopologyToRunningQueue(TopologyDetails topo, Cluster cluster)
boolean	equals(Object o)
Double	getCPUResourceGuaranteed()
double	getCPUResourcePoolUtilization()
double	getCPUResourceUsedByUser()
String	getDetailedInfo()
String	getId()
Double	getMemoryResourceGuaranteed()
double	getMemoryResourcePoolUtilization()
double	getMemoryResourceUsedByUser()
TopologyDetails	getNextTopologyToSchedule()
Map<String,Number>	getResourcePool()
double	getResourcePoolAverageUtilization()
static String	getResourcePoolAverageUtilizationForUsers(Collection<User> users)
TopologyDetails	getRunningTopologyWithLowestPriority()
Set<TopologyDetails>	getTopologiesAttempted()
Set<TopologyDetails>	getTopologiesInvalid()
Set<TopologyDetails>	getTopologiesPending()
Set<TopologyDetails>	getTopologiesRunning()
int	hashCode()
boolean	hasTopologyNeedSchedule()
void	moveTopoFromPendingToAttempted(TopologyDetails topo)
void	moveTopoFromPendingToAttempted(TopologyDetails topo, Cluster cluster)
void	moveTopoFromPendingToInvalid(TopologyDetails topo)
void	moveTopoFromPendingToInvalid(TopologyDetails topo, Cluster cluster)
void	moveTopoFromPendingToRunning(TopologyDetails topo)
void	moveTopoFromPendingToRunning(TopologyDetails topo, Cluster cluster)
void	moveTopoFromRunningToPending(TopologyDetails topo)
void	moveTopoFromRunningToPending(TopologyDetails topo, Cluster cluster)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

User

public User(String userId)

User

public User(String userId,
            Map<String,Double> resourcePool)

User

public User(User src)

Copy Constructor

Method Detail

getId

public String getId()

addTopologyToPendingQueue

public void addTopologyToPendingQueue(TopologyDetails topo,
                                      Cluster cluster)

addTopologyToPendingQueue

public void addTopologyToPendingQueue(TopologyDetails topo)

addTopologyToRunningQueue

public void addTopologyToRunningQueue(TopologyDetails topo,
                                      Cluster cluster)

addTopologyToRunningQueue

public void addTopologyToRunningQueue(TopologyDetails topo)

getTopologiesPending

public Set<TopologyDetails> getTopologiesPending()

addTopologyToAttemptedQueue

public void addTopologyToAttemptedQueue(TopologyDetails topo)

addTopologyToInvalidQueue

public void addTopologyToInvalidQueue(TopologyDetails topo)

getTopologiesRunning

public Set<TopologyDetails> getTopologiesRunning()

getTopologiesAttempted

public Set<TopologyDetails> getTopologiesAttempted()

getTopologiesInvalid

public Set<TopologyDetails> getTopologiesInvalid()

getResourcePool

public Map<String,Number> getResourcePool()

moveTopoFromPendingToRunning

public void moveTopoFromPendingToRunning(TopologyDetails topo,
                                         Cluster cluster)

moveTopoFromPendingToRunning

public void moveTopoFromPendingToRunning(TopologyDetails topo)

moveTopoFromPendingToAttempted

public void moveTopoFromPendingToAttempted(TopologyDetails topo,
                                           Cluster cluster)

moveTopoFromPendingToAttempted

public void moveTopoFromPendingToAttempted(TopologyDetails topo)

moveTopoFromPendingToInvalid

public void moveTopoFromPendingToInvalid(TopologyDetails topo,
                                         Cluster cluster)

moveTopoFromPendingToInvalid

public void moveTopoFromPendingToInvalid(TopologyDetails topo)

moveTopoFromRunningToPending

public void moveTopoFromRunningToPending(TopologyDetails topo,
                                         Cluster cluster)

moveTopoFromRunningToPending

public void moveTopoFromRunningToPending(TopologyDetails topo)

getResourcePoolAverageUtilization

public double getResourcePoolAverageUtilization()

getCPUResourcePoolUtilization

public double getCPUResourcePoolUtilization()

getMemoryResourcePoolUtilization

public double getMemoryResourcePoolUtilization()

getCPUResourceUsedByUser

public double getCPUResourceUsedByUser()

getMemoryResourceUsedByUser

public double getMemoryResourceUsedByUser()

getMemoryResourceGuaranteed

public Double getMemoryResourceGuaranteed()

getCPUResourceGuaranteed

public Double getCPUResourceGuaranteed()

getNextTopologyToSchedule

public TopologyDetails getNextTopologyToSchedule()

hasTopologyNeedSchedule

public boolean hasTopologyNeedSchedule()

getRunningTopologyWithLowestPriority

public TopologyDetails getRunningTopologyWithLowestPriority()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getDetailedInfo

public String getDetailedInfo()

getResourcePoolAverageUtilizationForUsers

public static String getResourcePoolAverageUtilizationForUsers(Collection<User> users)