Uses of Class
org.apache.storm.scheduler.Cluster

Packages that use Cluster

Package	Description
org.apache.storm.scheduler
org.apache.storm.scheduler.multitenant
org.apache.storm.scheduler.resource

Uses of Cluster in org.apache.storm.scheduler

Methods in org.apache.storm.scheduler with parameters of type Cluster

Modifier and Type	Method and Description
void	IScheduler.schedule(Topologies topologies, Cluster cluster) Set assignments for the topologies which needs scheduling.

Constructors in org.apache.storm.scheduler with parameters of type Cluster

Constructor and Description
Cluster(Cluster src) Copy constructor

Uses of Cluster in org.apache.storm.scheduler.multitenant

Fields in org.apache.storm.scheduler.multitenant declared as Cluster

Modifier and Type	Field and Description
protected Cluster	NodePool._cluster

Methods in org.apache.storm.scheduler.multitenant with parameters of type Cluster

Modifier and Type	Method and Description
void	Node.assign(String topId, Collection<ExecutorDetails> executors, Cluster cluster) Assign a free slot on the node to the following topology and executors.
void	Node.free(WorkerSlot ws, Cluster cluster, boolean forceFree) Frees a single slot in this node
void	Node.freeAllSlots(Cluster cluster) Free all slots on this node.
void	Node.freeTopology(String topId, Cluster cluster) Frees all the slots for a topology.
static Map<String,Node>	Node.getAllNodesFrom(Cluster cluster)
void	NodePool.init(Cluster cluster, Map<String,Node> nodeIdToNode) Initialize the pool.
void	FreePool.init(Cluster cluster, Map<String,Node> nodeIdToNode)
void	MultitenantScheduler.schedule(Topologies topologies, Cluster cluster)

Constructors in org.apache.storm.scheduler.multitenant with parameters of type Cluster

Constructor and Description
RoundRobinSlotScheduler(TopologyDetails td, int slotsToUse, Cluster cluster) Create a new scheduler for a given topology

Uses of Cluster in org.apache.storm.scheduler.resource

Fields in org.apache.storm.scheduler.resource declared as Cluster

Modifier and Type	Field and Description
Cluster	SchedulingState.cluster

Methods in org.apache.storm.scheduler.resource with parameters of type Cluster

Modifier and Type	Method and Description
void	User.addTopologyToPendingQueue(TopologyDetails topo, Cluster cluster)
void	User.addTopologyToRunningQueue(TopologyDetails topo, Cluster cluster)
static Map<String,RAS_Node>	RAS_Nodes.getAllNodesFrom(Cluster cluster, Topologies topologies)
static Collection<ExecutorDetails>	RAS_Node.getExecutors(WorkerSlot ws, Cluster cluster)
void	User.moveTopoFromPendingToAttempted(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromPendingToInvalid(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromPendingToRunning(TopologyDetails topo, Cluster cluster)
void	User.moveTopoFromRunningToPending(TopologyDetails topo, Cluster cluster)
static String	ResourceUtils.printScheduling(Cluster cluster, Topologies topologies) print scheduling for debug purposes
void	ResourceAwareScheduler.schedule(Topologies topologies, Cluster cluster)

Constructors in org.apache.storm.scheduler.resource with parameters of type Cluster

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