Uses of Class
org.apache.storm.scheduler.Cluster
Package
Description
-
Uses of Cluster in org.apache.storm.scheduler
Modifier and TypeClassDescriptionclass
A Cluster that only allows modification to a single topology.Modifier and TypeMethodDescriptionstatic void
DefaultScheduler.defaultSchedule
(Topologies topologies, Cluster cluster) static Map<WorkerSlot,
List<ExecutorDetails>> EvenScheduler.getAliveAssignedWorkerSlotExecutors
(Cluster cluster, String topologyId) void
DefaultScheduler.schedule
(Topologies topologies, Cluster cluster) void
EvenScheduler.schedule
(Topologies topologies, Cluster cluster) void
IScheduler.schedule
(Topologies topologies, Cluster cluster) Set assignments for the topologies which needs scheduling.void
IsolationScheduler.schedule
(Topologies topologies, Cluster cluster) static void
EvenScheduler.scheduleTopologiesEvenly
(Topologies topologies, Cluster cluster) static Set<WorkerSlot>
DefaultScheduler.slotsCanReassign
(Cluster cluster, Set<WorkerSlot> slots) void
Cluster.updateFrom
(Cluster other) Update the assignments and status from the other cluster.ModifierConstructorDescriptionCopy constructor.Cluster
(Cluster src, Topologies topologies) Testing Constructor that takes an existing cluster and replaces the topologies in it.SingleTopologyCluster
(Cluster other, String topologyId) Create a new cluster that only allows modifications to a single topology. -
Uses of Cluster in org.apache.storm.scheduler.blacklist
Modifier and TypeMethodDescriptionvoid
BlacklistScheduler.schedule
(Topologies topologies, Cluster cluster) -
Uses of Cluster in org.apache.storm.scheduler.blacklist.strategies
Modifier and TypeMethodDescriptionDefaultBlacklistStrategy.createHostToSupervisorMap
(List<String> blacklistedNodeIds, Cluster cluster) DefaultBlacklistStrategy.getBlacklist
(List<Map<String, Set<Integer>>> supervisorsWithFailures, List<Map<String, Integer>> sendAssignmentFailureCount, Cluster cluster, Topologies topologies) IBlacklistStrategy.getBlacklist
(List<Map<String, Set<Integer>>> badSupervisorsToleranceSlidingWindow, List<Map<String, Integer>> sendAssignmentFailureCount, Cluster cluster, Topologies topologies) Get blacklist by blacklist strategy.DefaultBlacklistStrategy.releaseBlacklistWhenNeeded
(Cluster cluster, List<String> blacklistedNodeIds) Decide when/if to release blacklisted hosts.RasBlacklistStrategy.releaseBlacklistWhenNeeded
(Cluster cluster, List<String> blacklistedNodeIds) -
Uses of Cluster in org.apache.storm.scheduler.multitenant
Modifier and TypeMethodDescriptionvoid
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.Node.getAllNodesFrom
(Cluster cluster) void
void
Initialize the pool.void
MultitenantScheduler.schedule
(Topologies topologies, Cluster cluster) ModifierConstructorDescriptionRoundRobinSlotScheduler
(TopologyDetails td, int slotsToUse, Cluster cluster) Create a new scheduler for a given topology. -
Uses of Cluster in org.apache.storm.scheduler.resource
Modifier and TypeMethodDescriptionRasNodes.getAllNodesFrom
(Cluster cluster) void
User.markTopoUnsuccess
(TopologyDetails topo, Cluster cluster, String msg) void
ResourceAwareScheduler.schedule
(Topologies topologies, Cluster cluster) ModifierConstructorDescriptionRasNode
(String nodeId, SupervisorDetails sup, Cluster cluster, Map<String, WorkerSlot> workerIdToWorker, Map<String, Map<String, Collection<ExecutorDetails>>> assignmentMap) Create a new node. -
Uses of Cluster in org.apache.storm.scheduler.resource.strategies.scheduling
Modifier and TypeMethodDescriptionprotected void
BaseResourceAwareStrategy.prepareForScheduling
(Cluster cluster, TopologyDetails topologyDetails) Initialize instance variables as the first step inBaseResourceAwareStrategy.schedule(Cluster, TopologyDetails)
.protected void
ConstraintSolverStrategy.prepareForScheduling
(Cluster cluster, TopologyDetails topologyDetails) BaseResourceAwareStrategy.schedule
(Cluster cluster, TopologyDetails td) Note that this method is not thread-safe.IStrategy.schedule
(Cluster schedulingState, TopologyDetails td) This method is invoked to calculate a scheduling for topology td.static boolean
ConstraintSolverStrategy.validateSolution
(Cluster cluster, TopologyDetails topo) Determines if a scheduling is valid and all constraints are satisfied (for use in testing). -
Uses of Cluster in org.apache.storm.scheduler.resource.strategies.scheduling.sorter
Modifier and TypeFieldDescriptionprotected Cluster
NodeSorter.cluster
protected Cluster
NodeSorterHostProximity.cluster
ModifierConstructorDescriptionExecSorterByConstraintSeverity
(Cluster cluster, TopologyDetails topologyDetails) NodeSorter
(Cluster cluster, TopologyDetails topologyDetails, BaseResourceAwareStrategy.NodeSortType nodeSortType) Initialize for the default implementation node sorting.NodeSorterHostProximity
(Cluster cluster, TopologyDetails topologyDetails) NodeSorterHostProximity
(Cluster cluster, TopologyDetails topologyDetails, BaseResourceAwareStrategy.NodeSortType nodeSortType) Initialize for the default implementation node sorting.