Package org.apache.storm.generated

Class Assignment

java.lang.Object
org.apache.storm.generated.Assignment
All Implemented Interfaces:
Serializable, Cloneable, Comparable<Assignment>, org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>, org.apache.storm.thrift.TSerializable
@Generated("Autogenerated by Thrift Compiler (0.19.0)") public class Assignment extends Object implements org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>, Serializable, Cloneable, Comparable<Assignment>
See Also:

  • Field Details

    • metaDataMap

      public static final Map<Assignment._Fields,org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap

  • Constructor Details

    • Assignment

      public Assignment()

    • Assignment

      public Assignment(String master_code_dir)

    • Assignment

      public Assignment(Assignment other)
      Performs a deep copy on other.

  • Method Details

    • deepCopy

      public Assignment deepCopy()
      Specified by:
      deepCopy in interface org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>

    • clear

      public void clear()
      Specified by:
      clear in interface org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>

    • get_master_code_dir

      public String get_master_code_dir()

    • set_master_code_dir

      public void set_master_code_dir(String master_code_dir)

    • unset_master_code_dir

      public void unset_master_code_dir()

    • is_set_master_code_dir

      public boolean is_set_master_code_dir()
      Returns true if field master_code_dir is set (has been assigned a value) and false otherwise

    • set_master_code_dir_isSet

      public void set_master_code_dir_isSet(boolean value)

    • get_node_host_size

      public int get_node_host_size()

    • put_to_node_host

      public void put_to_node_host(String key, String val)

    • get_node_host

      public Map<String,String> get_node_host()

    • set_node_host

      public void set_node_host(Map<String,String> node_host)

    • unset_node_host

      public void unset_node_host()

    • is_set_node_host

      public boolean is_set_node_host()
      Returns true if field node_host is set (has been assigned a value) and false otherwise

    • set_node_host_isSet

      public void set_node_host_isSet(boolean value)

    • get_executor_node_port_size

      public int get_executor_node_port_size()

    • put_to_executor_node_port

      public void put_to_executor_node_port(List<Long> key, NodeInfo val)

    • get_executor_node_port

      public Map<List<Long>,NodeInfo> get_executor_node_port()

    • set_executor_node_port

      public void set_executor_node_port(Map<List<Long>,NodeInfo> executor_node_port)

    • unset_executor_node_port

      public void unset_executor_node_port()

    • is_set_executor_node_port

      public boolean is_set_executor_node_port()
      Returns true if field executor_node_port is set (has been assigned a value) and false otherwise

    • set_executor_node_port_isSet

      public void set_executor_node_port_isSet(boolean value)

    • get_executor_start_time_secs_size

      public int get_executor_start_time_secs_size()

    • put_to_executor_start_time_secs

      public void put_to_executor_start_time_secs(List<Long> key, long val)

    • get_executor_start_time_secs

      public Map<List<Long>,Long> get_executor_start_time_secs()

    • set_executor_start_time_secs

      public void set_executor_start_time_secs(Map<List<Long>,Long> executor_start_time_secs)

    • unset_executor_start_time_secs

      public void unset_executor_start_time_secs()

    • is_set_executor_start_time_secs

      public boolean is_set_executor_start_time_secs()
      Returns true if field executor_start_time_secs is set (has been assigned a value) and false otherwise

    • set_executor_start_time_secs_isSet

      public void set_executor_start_time_secs_isSet(boolean value)

    • get_worker_resources_size

      public int get_worker_resources_size()

    • put_to_worker_resources

      public void put_to_worker_resources(NodeInfo key, WorkerResources val)

    • get_worker_resources

      public Map<NodeInfo,WorkerResources> get_worker_resources()

    • set_worker_resources

      public void set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources)

    • unset_worker_resources

      public void unset_worker_resources()

    • is_set_worker_resources

      public boolean is_set_worker_resources()
      Returns true if field worker_resources is set (has been assigned a value) and false otherwise

    • set_worker_resources_isSet

      public void set_worker_resources_isSet(boolean value)

    • get_total_shared_off_heap_size

      public int get_total_shared_off_heap_size()

    • put_to_total_shared_off_heap

      public void put_to_total_shared_off_heap(String key, double val)

    • get_total_shared_off_heap

      public Map<String,Double> get_total_shared_off_heap()

    • set_total_shared_off_heap

      public void set_total_shared_off_heap(Map<String,Double> total_shared_off_heap)

    • unset_total_shared_off_heap

      public void unset_total_shared_off_heap()

    • is_set_total_shared_off_heap

      public boolean is_set_total_shared_off_heap()
      Returns true if field total_shared_off_heap is set (has been assigned a value) and false otherwise

    • set_total_shared_off_heap_isSet

      public void set_total_shared_off_heap_isSet(boolean value)

    • get_owner

      public String get_owner()

    • set_owner

      public void set_owner(String owner)

    • unset_owner

      public void unset_owner()

    • is_set_owner

      public boolean is_set_owner()
      Returns true if field owner is set (has been assigned a value) and false otherwise

    • set_owner_isSet

      public void set_owner_isSet(boolean value)

    • setFieldValue

      public void setFieldValue(Assignment._Fields field, Object value)
      Specified by:
      setFieldValue in interface org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>

    • getFieldValue

      public Object getFieldValue(Assignment._Fields field)
      Specified by:
      getFieldValue in interface org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>

    • isSet

      public boolean isSet(Assignment._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<Assignment,Assignment._Fields>

    • equals

      public boolean equals(Object that)
      Overrides:
      equals in class Object

    • equals

      public boolean equals(Assignment that)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • compareTo

      public int compareTo(Assignment other)
      Specified by:
      compareTo in interface Comparable<Assignment>

    • fieldForId

      public Assignment._Fields fieldForId(int fieldId)
      Specified by:
      fieldForId in interface org.apache.storm.thrift.TBase<Assignment,Assignment._Fields>

    • 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

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • validate

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