backtype.storm.utils
Class ShellProcess
java.lang.Object
backtype.storm.utils.ShellProcess
public class ShellProcess
- extends java.lang.Object
Constructor Summary |
ShellProcess(java.lang.String[] command)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ShellProcess
public ShellProcess(java.lang.String[] command)
launch
public java.lang.Number launch(java.util.Map conf,
TopologyContext context)
throws java.io.IOException
- Throws:
java.io.IOException
destroy
public void destroy()
writeMessage
public void writeMessage(java.lang.Object msg)
throws java.io.IOException
- Throws:
java.io.IOException
readMessage
public JSONObject readMessage()
throws java.io.IOException
- Throws:
java.io.IOException
getErrorsString
public java.lang.String getErrorsString()