Class SupervisorUtils
java.lang.Object
org.apache.storm.daemon.supervisor.SupervisorUtils
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic boolean
blobNeedsWorkerRestart
(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 String
getNumaIdForPort
(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 LSWorkerHeartbeat
readWorkerHeartbeatImpl
(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 void
static void
static void
static boolean
shouldUncompressBlob
(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
-