Package org.apache.storm.multilang
Class ShellMsg
java.lang.Object
org.apache.storm.multilang.ShellMsg
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 SummaryNested Classes
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidvoidbooleangetId()getMsg()longgetTask()getTuple()voidsetAnchors(List<String> anchors) voidsetCommand(String command) voidvoidsetLogLevel(int logLevel) voidsetMetricName(String metricName) voidsetMetricParams(Object metricParams) voidvoidsetNeedTaskIds(boolean needTaskIds) voidvoidsetTask(long task) voidtoString()
- 
Constructor Details- 
ShellMsgpublic ShellMsg()
 
- 
- 
Method Details- 
getCommand
- 
setCommand
- 
getId
- 
setId
- 
getAnchors
- 
setAnchors
- 
addAnchor
- 
getStream
- 
setStream
- 
getTaskpublic long getTask()
- 
setTaskpublic void setTask(long task) 
- 
getMsg
- 
setMsg
- 
getTuple
- 
setTuple
- 
addTuple
- 
areTaskIdsNeededpublic boolean areTaskIdsNeeded()
- 
setNeedTaskIdspublic void setNeedTaskIds(boolean needTaskIds) 
- 
getMetricName
- 
setMetricName
- 
getMetricParams
- 
setMetricParams
- 
getLogLevel
- 
setLogLevelpublic void setLogLevel(int logLevel) 
- 
toString
 
-