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 Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier 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
-
ShellMsg
public ShellMsg()
-
-
Method Details
-
getCommand
-
setCommand
-
getId
-
setId
-
getAnchors
-
setAnchors
-
addAnchor
-
getStream
-
setStream
-
getTask
public long getTask() -
setTask
public void setTask(long task) -
getMsg
-
setMsg
-
getTuple
-
setTuple
-
addTuple
-
areTaskIdsNeeded
public boolean areTaskIdsNeeded() -
setNeedTaskIds
public void setNeedTaskIds(boolean needTaskIds) -
getMetricName
-
setMetricName
-
getMetricParams
-
setMetricParams
-
getLogLevel
-
setLogLevel
public void setLogLevel(int logLevel) -
toString
-