org.apache.storm.scheduler.resource

Class RAS_Node

java.lang.Object

org.apache.storm.scheduler.resource.RAS_Node

public class RAS_Node
extends Object

Represents a single node in the cluster.

Constructor Summary

Constructors

Constructor and Description
RAS_Node(String nodeId, SupervisorDetails sup, Cluster cluster, Topologies topologies, Map<String,WorkerSlot> workerIdToWorker, Map<String,Map<String,Collection<ExecutorDetails>>> assignmentMap)

Method Summary

Modifier and Type	Method and Description
void	assign(WorkerSlot target, TopologyDetails td, Collection<ExecutorDetails> executors) Assigns a worker to a node
Double	consumeCPU(Double amount) Consumes a certain amount of cpu for this node
Double	consumeMemory(Double amount) Consumes a certain amount of memory for this node
void	consumeResourcesforTask(ExecutorDetails exec, TopologyDetails topo) Consumes a certain amount of resources for a executor in a topology.
static int	countFreeSlotsAlive(Collection<RAS_Node> nodes)
static int	countSlotsUsed(Collection<RAS_Node> nodes)
static int	countSlotsUsed(String topId, Collection<RAS_Node> nodes)
static int	countTotalSlotsAlive(Collection<RAS_Node> nodes)
boolean	equals(Object other)
TopologyDetails	findTopologyUsingWorker(WorkerSlot ws) Find a which topology is running on a worker slot
void	free(WorkerSlot ws) Frees a single slot in this node
void	freeAllSlots() Free all slots on this node.
void	freeResourcesForTask(ExecutorDetails exec, TopologyDetails topo) frees the amount of resources for a executor in a topology.
Double	getAvailableCpuResources() Gets the available cpu resources for this node
Double	getAvailableMemoryResources() Gets the available memory resources for this node
double	getCpuUsedByWorker(WorkerSlot ws) get the amount of cpu used by a worker
static Collection<ExecutorDetails>	getExecutors(WorkerSlot ws, Cluster cluster)
Collection<WorkerSlot>	getFreeSlots()
Collection<String>	getFreeSlotsId()
String	getHostname()
String	getId()
double	getMemoryUsedByWorker(WorkerSlot ws) get the amount of memory used by a worker
Collection<String>	getRunningTopologies()
Double	getTotalCpuResources() Gets the total cpu resources for this node
Double	getTotalMemoryResources() Gets the total memory resources for this node
Collection<WorkerSlot>	getUsedSlots()
Collection<WorkerSlot>	getUsedSlots(String topId)
Collection<String>	getUsedSlotsId()
int	hashCode()
boolean	isAlive()
boolean	isTotallyFree()
void	setAvailableMemory(Double amount) Sets the Available Memory for a node
String	toString()
int	totalSlots()
int	totalSlotsFree()
int	totalSlotsUsed()
int	totalSlotsUsed(String topId)

Methods inherited from class java.lang.Object

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

Constructor Detail

RAS_Node

public RAS_Node(String nodeId,
                SupervisorDetails sup,
                Cluster cluster,
                Topologies topologies,
                Map<String,WorkerSlot> workerIdToWorker,
                Map<String,Map<String,Collection<ExecutorDetails>>> assignmentMap)

Method Detail

getId

public String getId()

getHostname

public String getHostname()

getFreeSlotsId

public Collection<String> getFreeSlotsId()

getFreeSlots

public Collection<WorkerSlot> getFreeSlots()

getUsedSlotsId

public Collection<String> getUsedSlotsId()

getUsedSlots

public Collection<WorkerSlot> getUsedSlots()

getUsedSlots

public Collection<WorkerSlot> getUsedSlots(String topId)

isAlive

public boolean isAlive()

getRunningTopologies

public Collection<String> getRunningTopologies()

Returns:

a collection of the topology ids currently running on this node

isTotallyFree

public boolean isTotallyFree()

totalSlotsFree

public int totalSlotsFree()

totalSlotsUsed

public int totalSlotsUsed()

totalSlots

public int totalSlots()

totalSlotsUsed

public int totalSlotsUsed(String topId)

freeAllSlots

public void freeAllSlots()

Free all slots on this node. This will update the Cluster too.

free

public void free(WorkerSlot ws)

Frees a single slot in this node

Parameters:

ws - the slot to free

getMemoryUsedByWorker

public double getMemoryUsedByWorker(WorkerSlot ws)

get the amount of memory used by a worker

getCpuUsedByWorker

public double getCpuUsedByWorker(WorkerSlot ws)

get the amount of cpu used by a worker

findTopologyUsingWorker

public TopologyDetails findTopologyUsingWorker(WorkerSlot ws)

Find a which topology is running on a worker slot

Returns:

the topology using the worker slot. If worker slot is free then return null

assign

public void assign(WorkerSlot target,
                   TopologyDetails td,
                   Collection<ExecutorDetails> executors)

Assigns a worker to a node

Parameters:

target - the worker slot to assign the executors

td - the topology the executors are from

executors - executors to assign to the specified worker slot

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

countSlotsUsed

public static int countSlotsUsed(String topId,
                                 Collection<RAS_Node> nodes)

countSlotsUsed

public static int countSlotsUsed(Collection<RAS_Node> nodes)

countFreeSlotsAlive

public static int countFreeSlotsAlive(Collection<RAS_Node> nodes)

countTotalSlotsAlive

public static int countTotalSlotsAlive(Collection<RAS_Node> nodes)

getExecutors

public static Collection<ExecutorDetails> getExecutors(WorkerSlot ws,
                                                       Cluster cluster)

setAvailableMemory

public void setAvailableMemory(Double amount)

Sets the Available Memory for a node

Parameters:

amount - the amount to set as available memory

getAvailableMemoryResources

public Double getAvailableMemoryResources()

Gets the available memory resources for this node

Returns:

the available memory for this node

getTotalMemoryResources

public Double getTotalMemoryResources()

Gets the total memory resources for this node

Returns:

the total memory for this node

consumeMemory

public Double consumeMemory(Double amount)

Consumes a certain amount of memory for this node

Parameters:

amount - is the amount memory to consume from this node

Returns:

the current available memory for this node after consumption

getAvailableCpuResources

public Double getAvailableCpuResources()

Gets the available cpu resources for this node

Returns:

the available cpu for this node

getTotalCpuResources

public Double getTotalCpuResources()

Gets the total cpu resources for this node

Returns:

the total cpu for this node

consumeCPU

public Double consumeCPU(Double amount)

Consumes a certain amount of cpu for this node

Parameters:

amount - is the amount cpu to consume from this node

Returns:

the current available cpu for this node after consumption

consumeResourcesforTask

public void consumeResourcesforTask(ExecutorDetails exec,
                                    TopologyDetails topo)

Consumes a certain amount of resources for a executor in a topology.

Parameters:

exec - is the executor that is consuming resources on this node

topo - the topology the executor is a part

freeResourcesForTask

public void freeResourcesForTask(ExecutorDetails exec,
                                 TopologyDetails topo)

frees the amount of resources for a executor in a topology.

Parameters:

exec - is the executor for which the resources are freed for

topo - the topology the executor is a part