Class SupervisorUtils
java.lang.Object
org.apache.storm.daemon.supervisor.SupervisorUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic booleanblobNeedsWorkerRestart(Map<String, Object> blobInfo) Given the blob information returns the value of the workerRestart field, handling it being a boolean value, or if it's not specified then returns false.static List<LocalResource>Returns a list of LocalResources based on the blobstore-map passed in.static StringgetNumaIdForPort(Integer port, Map<String, Object> supervisorConf) getNumaIdForPort for a specific supervisor.getNumaMap(Map<String, Object> stormConf) Return supervisor numa configuration.getNumaPorts(Map<String, Object> supervisorConf) gets the set of all configured numa ports for a specific supervisor.getSlotsPorts(Map<String, Object> supervisorConf) protected LSWorkerHeartbeatreadWorkerHeartbeatImpl(Map<String, Object> conf, String workerId) static Map<String,LSWorkerHeartbeat> readWorkerHeartbeats(Map<String, Object> conf) Map from worker id to heartbeat.readWorkerHeartbeatsImpl(Map<String, Object> conf) static voidstatic voidstatic voidstatic booleanshouldUncompressBlob(Map<String, Object> blobInfo) Given the blob information returns the value of the uncompress field, handling it being a boolean value, or if it's not specified then returns false.static Collection<String>supervisorWorkerIds(Map<String, Object> conf)
-
Constructor Details
-
SupervisorUtils
public SupervisorUtils()
-
-
Method Details
-
setInstance
-
resetInstance
public static void resetInstance() -
getNumaIdForPort
getNumaIdForPort for a specific supervisor.- Parameters:
port- portsupervisorConf- supervisorConf- Returns:
- getNumaIdForPort
-
getNumaPorts
gets the set of all configured numa ports for a specific supervisor.- Parameters:
supervisorConf- supervisorConf- Returns:
- set of all numa ports
-
getSlotsPorts
-
rmrAsUser
- Throws:
IOException
-
shouldUncompressBlob
Given the blob information returns the value of the uncompress field, handling it being a boolean value, or if it's not specified then returns false. -
blobNeedsWorkerRestart
Given the blob information returns the value of the workerRestart field, handling it being a boolean value, or if it's not specified then returns false.- Parameters:
blobInfo- the info for the blob.- Returns:
- true if the blob needs a worker restart by way of the callback else false.
-
blobstoreMapToLocalresources
public static List<LocalResource> blobstoreMapToLocalresources(Map<String, Map<String, Object>> blobstoreMap) Returns a list of LocalResources based on the blobstore-map passed in. -
supervisorWorkerIds
-
readWorkerHeartbeats
Map from worker id to heartbeat. -
getNumaMap
Return supervisor numa configuration.- Parameters:
stormConf- stormConf- Returns:
- getNumaMap
-
readWorkerHeartbeatsImpl
-
readWorkerHeartbeatImpl
-