Package | Description |
---|---|
backtype.storm.scheduler |
Modifier and Type | Method and Description |
---|---|
Collection<ExecutorDetails> |
TopologyDetails.getExecutors() |
Set<ExecutorDetails> |
SchedulerAssignmentImpl.getExecutors()
Return the executors covered by this assignments
|
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)
Gets a component-id -> executors map which needs scheduling in this topology.
|
Map<ExecutorDetails,String> |
Cluster.getNeedsSchedulingExecutorToComponents(TopologyDetails topology)
Gets a executor -> component-id map which needs scheduling in this topology.
|
Collection<ExecutorDetails> |
Cluster.getUnassignedExecutors(TopologyDetails topology)
get the unassigned executors of the topology.
|
Map<ExecutorDetails,String> |
TopologyDetails.selectExecutorToComponent(Collection<ExecutorDetails> executors) |
Modifier and Type | Method and Description |
---|---|
boolean |
SchedulerAssignmentImpl.isExecutorAssigned(ExecutorDetails executor) |
boolean |
SchedulerAssignment.isExecutorAssigned(ExecutorDetails executor)
is the executor assigned?
|
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 and Description |
---|
SchedulerAssignmentImpl(String topologyId,
Map<ExecutorDetails,WorkerSlot> executorToSlots) |
TopologyDetails(String topologyId,
Map topologyConf,
StormTopology topology,
int numWorkers,
Map<ExecutorDetails,String> executorToComponents) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.