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)

Method Summary

void	destroy()
java.lang.Number	launch(java.util.Map conf, TopologyContext context)
JSONObject	readMessage()
void	writeMessage(java.lang.Object msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

ShellProcess

public ShellProcess(java.lang.String[] command)

Method Detail

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