Package org.apache.storm.scheduler
Class SingleTopologyCluster
java.lang.Object
org.apache.storm.scheduler.Cluster
org.apache.storm.scheduler.SingleTopologyCluster
- All Implemented Interfaces:
- ISchedulingState
A Cluster that only allows modification to a single topology.
- 
Constructor SummaryConstructorsConstructorDescriptionSingleTopologyCluster(Cluster other, String topologyId) Create a new cluster that only allows modifications to a single topology.
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidassertValidTopologyForModification(String topologyId) Check if the given topology is allowed for modification right now.Methods inherited from class org.apache.storm.scheduler.Clusterassign, assign, blacklistHost, freeSlot, freeSlots, getAllScheduledResourcesForNode, getAssignablePorts, getAssignableSlots, getAssignableSlots, getAssignedMemoryForSlot, getAssignedNumWorkers, getAssignmentById, getAssignments, getAvailablePorts, getAvailableResources, getAvailableSlots, getAvailableSlots, getBlacklistedHosts, getClusterTotalCpuResource, getClusterTotalGenericResources, getClusterTotalMemoryResource, getConf, getGreyListedSupervisors, getHost, getINimbus, getMinWorkerCpu, getNeedsSchedulingComponentToExecutors, getNeedsSchedulingExecutorToComponents, getNetworkTopography, getNonBlacklistedAvailableSlots, getNonBlacklistedClusterAvailableResources, getResourceMetrics, getScheduledCpuForNode, getScheduledMemoryForNode, getStatus, getStatusMap, getSupervisorById, getSupervisors, getSupervisorsByHost, getSupervisorsResourcesMap, getTopologies, getTopologyResourcesMap, getUnassignedExecutors, getUsedPorts, getUsedSlots, getUsedSlotsByTopologyId, getWorkerResources, getWorkerResourcesMap, isBlackListed, isBlacklistedHost, isSlotOccupied, needsScheduling, needsSchedulingRas, needsSchedulingTopologies, setAssignments, setBlacklistedHosts, setGreyListedSupervisors, setNetworkTopography, setStatus, setStatus, setStatusIfAbsent, setStatusMap, unassign, updateFrom, wouldFitMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.scheduler.ISchedulingStategetAssignedRacks, getHostToRack
- 
Constructor Details- 
SingleTopologyClusterCreate a new cluster that only allows modifications to a single topology.- Parameters:
- other- the current cluster to base this off of
- topologyId- the topology that is allowed to be modified.
 
 
- 
- 
Method Details- 
assertValidTopologyForModificationDescription copied from class:ClusterCheck if the given topology is allowed for modification right now. If not throw an IllegalArgumentException else go on.- Overrides:
- assertValidTopologyForModificationin class- Cluster
- Parameters:
- topologyId- the id of the topology to check
 
 
-