Package org.apache.storm.multilang
Class ShellMsg
- java.lang.Object
-
- org.apache.storm.multilang.ShellMsg
-
public class ShellMsg extends Object
ShellMsg is an object that represents the data sent to a shell component from a process that implements a multi-language protocol. It is the union of all data types that a component can send to Storm.ShellMsgs are objects received from the ISerializer interface, after the serializer has deserialized the data from the underlying wire protocol. The ShellMsg class allows for a decoupling between the serialized representation of the data and the data itself.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classShellMsg.ShellLogLevel
-
Constructor Summary
Constructors Constructor Description ShellMsg()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddAnchor(String anchor)voidaddTuple(Object tuple)booleanareTaskIdsNeeded()List<String>getAnchors()StringgetCommand()ObjectgetId()ShellMsg.ShellLogLevelgetLogLevel()StringgetMetricName()ObjectgetMetricParams()StringgetMsg()StringgetStream()longgetTask()List<Object>getTuple()voidsetAnchors(List<String> anchors)voidsetCommand(String command)voidsetId(Object id)voidsetLogLevel(int logLevel)voidsetMetricName(String metricName)voidsetMetricParams(Object metricParams)voidsetMsg(String msg)voidsetNeedTaskIds(boolean needTaskIds)voidsetStream(String stream)voidsetTask(long task)voidsetTuple(List<Object> tuple)StringtoString()
-
-
-
Method Detail
-
getCommand
public String getCommand()
-
setCommand
public void setCommand(String command)
-
getId
public Object getId()
-
setId
public void setId(Object id)
-
addAnchor
public void addAnchor(String anchor)
-
getStream
public String getStream()
-
setStream
public void setStream(String stream)
-
getTask
public long getTask()
-
setTask
public void setTask(long task)
-
getMsg
public String getMsg()
-
setMsg
public void setMsg(String msg)
-
addTuple
public void addTuple(Object tuple)
-
areTaskIdsNeeded
public boolean areTaskIdsNeeded()
-
setNeedTaskIds
public void setNeedTaskIds(boolean needTaskIds)
-
getMetricName
public String getMetricName()
-
setMetricName
public void setMetricName(String metricName)
-
getMetricParams
public Object getMetricParams()
-
setMetricParams
public void setMetricParams(Object metricParams)
-
getLogLevel
public ShellMsg.ShellLogLevel getLogLevel()
-
setLogLevel
public void setLogLevel(int logLevel)
-
-