Class ShellProcess

java.lang.Object
org.apache.storm.utils.ShellProcess
All Implemented Interfaces:
Serializable

public class ShellProcess extends Object implements Serializable
See Also:
  • Field Details

    • LOG

      public static final org.slf4j.Logger LOG
    • ShellLogger

      public static org.slf4j.Logger ShellLogger
    • serializer

      public ISerializer serializer
    • pid

      public Number pid
    • componentName

      public String componentName
  • Constructor Details

    • ShellProcess

      public ShellProcess(String[] command)
  • Method Details

    • setEnv

      public void setEnv(Map<String,String> env)
    • launch

      public Number launch(Map<String,Object> conf, TopologyContext context)
    • launch

      public Number launch(Map<String,Object> conf, TopologyContext context, boolean changeDirectory)
    • destroy

      public void destroy()
    • readShellMsg

      public ShellMsg readShellMsg() throws IOException
      Throws:
      IOException
    • writeBoltMsg

      public void writeBoltMsg(BoltMsg msg) throws IOException
      Throws:
      IOException
    • writeSpoutMsg

      public void writeSpoutMsg(SpoutMsg msg) throws IOException
      Throws:
      IOException
    • writeTaskIds

      public void writeTaskIds(List<Integer> taskIds) throws IOException
      Throws:
      IOException
    • logErrorStream

      public void logErrorStream()
    • getErrorsString

      public String getErrorsString()
    • getPid

      public Number getPid()
      Get PID.
      Returns:
      pid, if the process has been launched, null otherwise.
    • getComponentName

      public String getComponentName()
    • getExitCode

      public int getExitCode()
      Get exit code.
      Returns:
      exit code of the process if process is terminated, -1 if process is not started or terminated.
    • getProcessInfoString

      public String getProcessInfoString()
    • getProcessTerminationInfoString

      public String getProcessTerminationInfoString()