Package org.apache.storm.multilang

Class BoltMsg

java.lang.Object
org.apache.storm.multilang.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 Details

    • BoltMsg

      public BoltMsg()

  • Method Details

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

    • getTuple

      public List<Object> getTuple()

    • setTuple

      public void setTuple(List<Object> tuple)