public class SingleTopologyCluster extends Cluster
A Cluster that only allows modification to a single topology.
| Constructor and Description |
|---|
SingleTopologyCluster(Cluster other,
String topologyId)
Create a new cluster that only allows modifications to a single topology.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
assertValidTopologyForModification(String topologyId)
Check if the given topology is allowed for modification right now.
|
assign, 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, wouldFitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetAssignedRacks, getHostToRackprotected void assertValidTopologyForModification(String topologyId)
ClusterCheck if the given topology is allowed for modification right now. If not throw an IllegalArgumentException else go on.
assertValidTopologyForModification in class ClustertopologyId - the id of the topology to checkCopyright © 2021 The Apache Software Foundation. All rights reserved.