Package org.apache.storm.multilang

Class 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.

    • Constructor Detail

      • ShellMsg

        public ShellMsg()

    • Method Detail

      • getCommand

        public String getCommand()

      • setCommand

        public void setCommand​(String command)

      • getId

        public Object getId()

      • setId

        public void setId​(Object id)

      • setAnchors

        public void setAnchors​(List<String> anchors)

      • 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)

      • setTuple

        public void setTuple​(List<Object> tuple)

      • 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)

      • setLogLevel

        public void setLogLevel​(int logLevel)