Class StreamInfo

    • Field Detail

      • metaDataMap

        public static final Map<StreamInfo._Fields,​org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap
    • Constructor Detail

      • StreamInfo

        public StreamInfo()
      • StreamInfo

        public StreamInfo​(List<String> output_fields,
                          boolean direct)
      • StreamInfo

        public StreamInfo​(StreamInfo other)
        Performs a deep copy on other.
    • Method Detail

      • get_output_fields_size

        public int get_output_fields_size()
      • get_output_fields_iterator

        public Iterator<String> get_output_fields_iterator()
      • add_to_output_fields

        public void add_to_output_fields​(String elem)
      • get_output_fields

        public List<String> get_output_fields()
      • set_output_fields

        public void set_output_fields​(List<String> output_fields)
      • unset_output_fields

        public void unset_output_fields()
      • is_set_output_fields

        public boolean is_set_output_fields()
        Returns true if field output_fields is set (has been assigned a value) and false otherwise
      • set_output_fields_isSet

        public void set_output_fields_isSet​(boolean value)
      • is_direct

        public boolean is_direct()
      • set_direct

        public void set_direct​(boolean direct)
      • unset_direct

        public void unset_direct()
      • is_set_direct

        public boolean is_set_direct()
        Returns true if field direct is set (has been assigned a value) and false otherwise
      • set_direct_isSet

        public void set_direct_isSet​(boolean value)
      • isSet

        public boolean isSet​(StreamInfo._Fields field)
        Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
        Specified by:
        isSet in interface org.apache.storm.thrift.TBase<StreamInfo,​StreamInfo._Fields>
      • equals

        public boolean equals​(StreamInfo that)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • read

        public void read​(org.apache.storm.thrift.protocol.TProtocol iprot)
                  throws org.apache.storm.thrift.TException
        Specified by:
        read in interface org.apache.storm.thrift.TSerializable
        Throws:
        org.apache.storm.thrift.TException
      • write

        public void write​(org.apache.storm.thrift.protocol.TProtocol oprot)
                   throws org.apache.storm.thrift.TException
        Specified by:
        write in interface org.apache.storm.thrift.TSerializable
        Throws:
        org.apache.storm.thrift.TException
      • validate

        public void validate()
                      throws org.apache.storm.thrift.TException
        Throws:
        org.apache.storm.thrift.TException