org.apache.storm.daemon.supervisor

Class SupervisorUtils

java.lang.Object

org.apache.storm.daemon.supervisor.SupervisorUtils

public class SupervisorUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
SupervisorUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	blobNeedsWorkerRestart(Map<String,Object> blobInfo) Given the blob information returns the value of the workerRestart field, handling it either being a string or a boolean value, or if it’s not specified then returns false.
static List<LocalResource>	blobstoreMapToLocalresources(Map<String,Map<String,Object>> blobstoreMap) 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.
static Map<String,Object>	getNumaMap(Map<String,Object> stormConf) Return supervisor numa configuration.
static Set<Integer>	getNumaPorts(Map<String,Object> supervisorConf) gets the set of all configured numa ports for a specific supervisor.
static List<Integer>	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.
Map<String,LSWorkerHeartbeat>	readWorkerHeartbeatsImpl(Map<String,Object> conf)
static void	resetInstance()
static void	rmrAsUser(Map<String,Object> conf, String id, String path)
static void	setInstance(SupervisorUtils u)
static boolean	shouldUncompressBlob(Map<String,Object> blobInfo) Given the blob information returns the value of the uncompress field, handling it either being a string or a boolean value, or if it’s not specified then returns false.
static Collection<String>	supervisorWorkerIds(Map<String,Object> conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SupervisorUtils

public SupervisorUtils()

Method Detail

setInstance

public static void setInstance(SupervisorUtils u)

resetInstance

public static void resetInstance()

getNumaIdForPort

public static String getNumaIdForPort(Integer port,
                                      Map<String,Object> supervisorConf)

getNumaIdForPort for a specific supervisor.

Parameters:

port - port

supervisorConf - supervisorConf

Returns:

getNumaIdForPort

getNumaPorts

public static Set<Integer> getNumaPorts(Map<String,Object> supervisorConf)

gets the set of all configured numa ports for a specific supervisor.

Parameters:

supervisorConf - supervisorConf

Returns:

set of all numa ports

getSlotsPorts

public static List<Integer> getSlotsPorts(Map<String,Object> supervisorConf)

rmrAsUser

public static void rmrAsUser(Map<String,Object> conf,
                             String id,
                             String path)
                      throws IOException

Throws:

IOException

shouldUncompressBlob

public static boolean shouldUncompressBlob(Map<String,Object> blobInfo)

Given the blob information returns the value of the uncompress field, handling it either being a string or a boolean value, or if it’s not specified then returns false.

blobNeedsWorkerRestart

public static boolean blobNeedsWorkerRestart(Map<String,Object> blobInfo)

Given the blob information returns the value of the workerRestart field, handling it either being a string or 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

public static Collection<String> supervisorWorkerIds(Map<String,Object> conf)

readWorkerHeartbeats

public static Map<String,LSWorkerHeartbeat> readWorkerHeartbeats(Map<String,Object> conf)

Map from worker id to heartbeat.

getNumaMap

public static Map<String,Object> getNumaMap(Map<String,Object> stormConf)

Return supervisor numa configuration.

Parameters:

stormConf - stormConf

Returns:

getNumaMap

readWorkerHeartbeatsImpl

public Map<String,LSWorkerHeartbeat> readWorkerHeartbeatsImpl(Map<String,Object> conf)

readWorkerHeartbeatImpl

protected LSWorkerHeartbeat readWorkerHeartbeatImpl(Map<String,Object> conf,
                                                    String workerId)