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

Packages that use ExecutorDetails

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

Uses of ExecutorDetails in org.apache.storm.scheduler

Methods in org.apache.storm.scheduler that return types with arguments of type ExecutorDetails

Modifier and Type	Method and Description
Collection<ExecutorDetails>	TopologyDetails.getExecutors()
Set<ExecutorDetails>	SchedulerAssignmentImpl.getExecutors()
Set<ExecutorDetails>	SchedulerAssignment.getExecutors() Return the executors covered by this assignments
Map<ExecutorDetails,String>	TopologyDetails.getExecutorToComponent()
Map<ExecutorDetails,WorkerSlot>	SchedulerAssignmentImpl.getExecutorToSlot()
Map<ExecutorDetails,WorkerSlot>	SchedulerAssignment.getExecutorToSlot() get the executor -> slot map.
Map<String,List<ExecutorDetails>>	Cluster.getNeedsSchedulingComponentToExecutors(TopologyDetails topology)
Map<ExecutorDetails,String>	Cluster.getNeedsSchedulingExecutorToComponents(TopologyDetails topology)
Map<WorkerSlot,Collection<ExecutorDetails>>	SchedulerAssignmentImpl.getSlotToExecutors()
Map<WorkerSlot,Collection<ExecutorDetails>>	SchedulerAssignment.getSlotToExecutors()
Map<ExecutorDetails,Double>	TopologyDetails.getTotalMemoryResourceList() Gets the total memory resource list for a set of tasks that is part of a topology.
Collection<ExecutorDetails>	Cluster.getUnassignedExecutors(TopologyDetails topology) get the unassigned executors of the topology.
Map<ExecutorDetails,String>	TopologyDetails.selectExecutorToComponent(Collection<ExecutorDetails> executors)

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

Modifier and Type	Method and Description
void	TopologyDetails.addResourcesForExec(ExecutorDetails exec, Map<String,Double> resourceList) add resource requirements for a executor
Double	TopologyDetails.getOffHeapMemoryRequirement(ExecutorDetails exec) Gets the off heap memory requirement for a certain task within a topology
Double	TopologyDetails.getOnHeapMemoryRequirement(ExecutorDetails exec) Gets the on heap memory requirement for a certain task within a topology
Map<String,Double>	TopologyDetails.getTaskResourceReqList(ExecutorDetails exec) get the resources requirements for a executor
Double	TopologyDetails.getTotalCpuReqTask(ExecutorDetails exec) Get the total CPU requirement for executor
Double	TopologyDetails.getTotalMemReqTask(ExecutorDetails exec) Gets the total memory requirement for a task
boolean	TopologyDetails.hasExecInTopo(ExecutorDetails exec) Checks if a executor is part of this topology
boolean	SchedulerAssignmentImpl.isExecutorAssigned(ExecutorDetails executor)
boolean	SchedulerAssignment.isExecutorAssigned(ExecutorDetails executor) is the executor assigned?

Method parameters in org.apache.storm.scheduler with type arguments of type ExecutorDetails

Modifier and Type	Method and Description
void	SchedulerAssignmentImpl.assign(WorkerSlot slot, Collection<ExecutorDetails> executors) Assign the slot to executors.
void	Cluster.assign(WorkerSlot slot, String topologyId, Collection<ExecutorDetails> executors) Assign the slot to the executors for this topology.
Map<ExecutorDetails,String>	TopologyDetails.selectExecutorToComponent(Collection<ExecutorDetails> executors)

Constructor parameters in org.apache.storm.scheduler with type arguments of type ExecutorDetails

Constructor and Description
SchedulerAssignmentImpl(String topologyId, Map<ExecutorDetails,WorkerSlot> executorToSlots)
TopologyDetails(String topologyId, Map topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, int launchTime, String owner)
TopologyDetails(String topologyId, Map topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, String owner)

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

Method parameters in org.apache.storm.scheduler.multitenant with type arguments of type ExecutorDetails

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.

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

Fields in org.apache.storm.scheduler.resource with type parameters of type ExecutorDetails

Modifier and Type	Field and Description
List<ExecutorDetails>	Component.execs

Methods in org.apache.storm.scheduler.resource that return types with arguments of type ExecutorDetails

Modifier and Type	Method and Description
static Collection<ExecutorDetails>	RAS_Node.getExecutors(WorkerSlot ws, Cluster cluster)
Map<WorkerSlot,Collection<ExecutorDetails>>	SchedulingResult.getSchedulingResultMap()

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

Modifier and Type	Method and Description
void	RAS_Node.consumeResourcesforTask(ExecutorDetails exec, TopologyDetails topo) Consumes a certain amount of resources for a executor in a topology.
void	RAS_Node.freeResourcesForTask(ExecutorDetails exec, TopologyDetails topo) frees the amount of resources for a executor in a topology.

Method parameters in org.apache.storm.scheduler.resource with type arguments of type ExecutorDetails

Modifier and Type	Method and Description
void	RAS_Node.assign(WorkerSlot target, TopologyDetails td, Collection<ExecutorDetails> executors) Assigns a worker to a node
static SchedulingResult	SchedulingResult.success(Map<WorkerSlot,Collection<ExecutorDetails>> schedulingResultMap)
static SchedulingResult	SchedulingResult.successWithMsg(Map<WorkerSlot,Collection<ExecutorDetails>> schedulingResultMap, String message)

Constructor parameters in org.apache.storm.scheduler.resource with type arguments of type ExecutorDetails

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