Package org.apache.storm.utils
Class ShellProcess
java.lang.Object
org.apache.storm.utils.ShellProcess
- All Implemented Interfaces:
- Serializable
- See Also:
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final org.slf4j.Loggerstatic org.slf4j.Logger
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddestroy()intGet exit code.getPid()Get PID.launch(Map<String, Object> conf, TopologyContext context) launch(Map<String, Object> conf, TopologyContext context, boolean changeDirectory) voidvoidvoidwriteBoltMsg(BoltMsg msg) voidwriteSpoutMsg(SpoutMsg msg) voidwriteTaskIds(List<Integer> taskIds) 
- 
Field Details- 
LOGpublic static final org.slf4j.Logger LOG
- 
ShellLoggerpublic static org.slf4j.Logger ShellLogger
- 
serializer
- 
pid
- 
componentName
 
- 
- 
Constructor Details- 
ShellProcess
 
- 
- 
Method Details- 
setEnv
- 
launch
- 
launch
- 
destroypublic void destroy()
- 
readShellMsg- Throws:
- IOException
 
- 
writeBoltMsg- Throws:
- IOException
 
- 
writeSpoutMsg- Throws:
- IOException
 
- 
writeTaskIds- Throws:
- IOException
 
- 
logErrorStreampublic void logErrorStream()
- 
getErrorsString
- 
getPidGet PID.- Returns:
- pid, if the process has been launched, null otherwise.
 
- 
getComponentName
- 
getExitCodepublic int getExitCode()Get exit code.- Returns:
- exit code of the process if process is terminated, -1 if process is not started or terminated.
 
- 
getProcessInfoString
- 
getProcessTerminationInfoString
 
-