public class ShellProcess extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
String |
componentName |
static org.slf4j.Logger |
LOG |
Number |
pid |
ISerializer |
serializer |
static org.slf4j.Logger |
ShellLogger |
Constructor and Description |
---|
ShellProcess(String[] command) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
String |
getComponentName() |
String |
getErrorsString() |
int |
getExitCode() |
Number |
getPid() |
String |
getProcessInfoString() |
String |
getProcessTerminationInfoString() |
Number |
launch(Map conf,
TopologyContext context) |
Number |
launch(Map conf,
TopologyContext context,
boolean changeDirectory) |
void |
logErrorStream() |
ShellMsg |
readShellMsg() |
void |
setEnv(Map<String,String> env) |
void |
writeBoltMsg(BoltMsg msg) |
void |
writeSpoutMsg(SpoutMsg msg) |
void |
writeTaskIds(List<Integer> taskIds) |
public static final org.slf4j.Logger LOG
public static org.slf4j.Logger ShellLogger
public ISerializer serializer
public Number pid
public String componentName
public ShellProcess(String[] command)
public Number launch(Map conf, TopologyContext context)
public Number launch(Map conf, TopologyContext context, boolean changeDirectory)
public void destroy()
public ShellMsg readShellMsg() throws IOException
IOException
public void writeBoltMsg(BoltMsg msg) throws IOException
IOException
public void writeSpoutMsg(SpoutMsg msg) throws IOException
IOException
public void writeTaskIds(List<Integer> taskIds) throws IOException
IOException
public void logErrorStream()
public String getErrorsString()
public Number getPid()
public String getComponentName()
public int getExitCode()
public String getProcessInfoString()
public String getProcessTerminationInfoString()
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.