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 List<LocalResource>	blobstoreMapToLocalresources(Map<String,Map<String,Object>> blobstoreMap) Returns a list of LocalResources based on the blobstore-map passed in
static boolean	isWorkerHbTimedOut(int now, LSWorkerHeartbeat whb, Map<String,Object> conf)
static Process	launchProcess(List<String> command, Map<String,String> environment, String logPrefix, ExitCodeCallback exitCodeCallback, File dir) Launch a new process as per ProcessBuilder with a given callback.
static int	processLauncherAndWait(Map<String,Object> conf, String user, List<String> args, Map<String,String> environment, String logPreFix)
static Set<String>	readDownloadedTopologyIds(Map<String,Object> conf)
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 void	setupStormCodeDir(Map<String,Object> conf, String user, String dir)
static void	setupWorkerArtifactsDir(Map<String,Object> conf, String user, String dir)
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()

processLauncherAndWait

public static int processLauncherAndWait(Map<String,Object> conf,
                                         String user,
                                         List<String> args,
                                         Map<String,String> environment,
                                         String logPreFix)
                                  throws IOException

Throws:

IOException

setupStormCodeDir

public static void setupStormCodeDir(Map<String,Object> conf,
                                     String user,
                                     String dir)
                              throws IOException

Throws:

IOException

setupWorkerArtifactsDir

public static void setupWorkerArtifactsDir(Map<String,Object> conf,
                                           String user,
                                           String dir)
                                    throws IOException

Throws:

IOException

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

Parameters:

blobInfo -

Returns:

blobstoreMapToLocalresources

public static List<LocalResource> blobstoreMapToLocalresources(Map<String,Map<String,Object>> blobstoreMap)

Returns a list of LocalResources based on the blobstore-map passed in

Parameters:

blobstoreMap -

Returns:

readDownloadedTopologyIds

public static Set<String> readDownloadedTopologyIds(Map<String,Object> conf)
                                             throws IOException

Throws:

IOException

supervisorWorkerIds

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

readWorkerHeartbeats

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

map from worker id to heartbeat

Parameters:

conf -

Returns:

Throws:

Exception

readWorkerHeartbeatsImpl

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

Throws:

Exception

readWorkerHeartbeatImpl

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

isWorkerHbTimedOut

public static boolean isWorkerHbTimedOut(int now,
                                         LSWorkerHeartbeat whb,
                                         Map<String,Object> conf)

launchProcess

public static Process launchProcess(List<String> command,
                                    Map<String,String> environment,
                                    String logPrefix,
                                    ExitCodeCallback exitCodeCallback,
                                    File dir)
                             throws IOException

Launch a new process as per ProcessBuilder with a given callback.

Parameters:

command - the command to be executed in the new process

environment - the environment to be applied to the process. Can be null.

logPrefix - a prefix for log entries from the output of the process. Can be null.

exitCodeCallback - code to be called passing the exit code value when the process completes

dir - the working directory of the new process

Returns:

the new process

Throws:

IOException

See Also:

ProcessBuilder