public interface IBlacklistStrategy
Modifier and Type | Method and Description |
---|---|
Set<String> |
getBlacklist(List<Map<String,Set<Integer>>> badSupervisorsToleranceSlidingWindow,
Cluster cluster,
Topologies topologies)
Get blacklist by blacklist strategy.
|
void |
prepare(Map<String,Object> conf) |
void |
resumeFromBlacklist()
resume supervisors form blacklist.
|
Set<String> getBlacklist(List<Map<String,Set<Integer>>> badSupervisorsToleranceSlidingWindow, Cluster cluster, Topologies topologies)
Get blacklist by blacklist strategy.
badSupervisorsToleranceSlidingWindow
- bad supervisors buffered in sliding windowcluster
- the cluster these topologies are running in. cluster
contains everything user need to develop a new scheduling logic. e.g. supervisors information, available slots, current assignments for all the topologies etc. User can set the new assignment for topologies using cluster.setAssignmentById()`topologies
- all the topologies in the cluster, some of them need schedule. Topologies object here only contain static information about topologies. Information like assignments, slots are all in the cluster
object.void resumeFromBlacklist()
resume supervisors form blacklist. Blacklist is just a temporary list for supervisors, or there will be less and less available resources. This will be called every time before getBlacklist() and schedule.
Copyright © 2022 The Apache Software Foundation. All rights reserved.