Class RebalanceOptions

    • Constructor Detail

      • RebalanceOptions

        public RebalanceOptions()
      • RebalanceOptions

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

      • get_wait_secs

        public int get_wait_secs()
      • set_wait_secs

        public void set_wait_secs​(int wait_secs)
      • unset_wait_secs

        public void unset_wait_secs()
      • is_set_wait_secs

        public boolean is_set_wait_secs()
        Returns true if field wait_secs is set (has been assigned a value) and false otherwise
      • set_wait_secs_isSet

        public void set_wait_secs_isSet​(boolean value)
      • get_num_workers

        public int get_num_workers()
      • set_num_workers

        public void set_num_workers​(int num_workers)
      • unset_num_workers

        public void unset_num_workers()
      • is_set_num_workers

        public boolean is_set_num_workers()
        Returns true if field num_workers is set (has been assigned a value) and false otherwise
      • set_num_workers_isSet

        public void set_num_workers_isSet​(boolean value)
      • get_num_executors_size

        public int get_num_executors_size()
      • put_to_num_executors

        public void put_to_num_executors​(String key,
                                         int val)
      • set_num_executors

        public void set_num_executors​(Map<String,​Integer> num_executors)
      • unset_num_executors

        public void unset_num_executors()
      • is_set_num_executors

        public boolean is_set_num_executors()
        Returns true if field num_executors is set (has been assigned a value) and false otherwise
      • set_num_executors_isSet

        public void set_num_executors_isSet​(boolean value)
      • get_topology_resources_overrides_size

        public int get_topology_resources_overrides_size()
      • put_to_topology_resources_overrides

        public void put_to_topology_resources_overrides​(String key,
                                                        Map<String,​Double> val)
      • set_topology_resources_overrides

        public void set_topology_resources_overrides​(Map<String,​Map<String,​Double>> topology_resources_overrides)
      • unset_topology_resources_overrides

        public void unset_topology_resources_overrides()
      • is_set_topology_resources_overrides

        public boolean is_set_topology_resources_overrides()
        Returns true if field topology_resources_overrides is set (has been assigned a value) and false otherwise
      • set_topology_resources_overrides_isSet

        public void set_topology_resources_overrides_isSet​(boolean value)
      • get_topology_conf_overrides

        public String get_topology_conf_overrides()
      • set_topology_conf_overrides

        public void set_topology_conf_overrides​(String topology_conf_overrides)
      • unset_topology_conf_overrides

        public void unset_topology_conf_overrides()
      • is_set_topology_conf_overrides

        public boolean is_set_topology_conf_overrides()
        Returns true if field topology_conf_overrides is set (has been assigned a value) and false otherwise
      • set_topology_conf_overrides_isSet

        public void set_topology_conf_overrides_isSet​(boolean value)
      • get_principal

        public String get_principal()
      • set_principal

        public void set_principal​(String principal)
      • unset_principal

        public void unset_principal()
      • is_set_principal

        public boolean is_set_principal()
        Returns true if field principal is set (has been assigned a value) and false otherwise
      • set_principal_isSet

        public void set_principal_isSet​(boolean value)
      • 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