Class BoltMsg


  • public class BoltMsg
    extends Object
    BoltMsg is an object that represents the data sent from a shell component to a bolt process that implements a multi-language protocol. It is the union of all data types that a bolt can receive from Storm.

    BoltMsgs are objects sent to the ISerializer interface, for serialization according to the wire protocol implemented by the serializer. The BoltMsg class allows for a decoupling between the serialized representation of the data and the data itself.

    • Constructor Detail

      • BoltMsg

        public BoltMsg()
    • Method Detail

      • getId

        public String getId()
      • setId

        public void setId​(String id)
      • getComp

        public String getComp()
      • setComp

        public void setComp​(String comp)
      • getStream

        public String getStream()
      • setStream

        public void setStream​(String stream)
      • getTask

        public long getTask()
      • setTask

        public void setTask​(long task)
      • setTuple

        public void setTuple​(List<Object> tuple)