@Generated(value="Autogenerated by Thrift Compiler (0.13.0)") public class LSWorkerHeartbeat extends Object implements org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>, Serializable, Cloneable, Comparable<LSWorkerHeartbeat>
Modifier and Type | Class and Description |
---|---|
static class |
LSWorkerHeartbeat._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
|
Modifier and Type | Field and Description |
---|---|
static Map<LSWorkerHeartbeat._Fields,org.apache.storm.thrift.meta_data.FieldMetaData> |
metaDataMap |
Constructor and Description |
---|
LSWorkerHeartbeat() |
LSWorkerHeartbeat(int time_secs,
String topology_id,
List<ExecutorInfo> executors,
int port) |
LSWorkerHeartbeat(LSWorkerHeartbeat other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
void |
add_to_executors(ExecutorInfo elem) |
void |
clear() |
int |
compareTo(LSWorkerHeartbeat other) |
LSWorkerHeartbeat |
deepCopy() |
boolean |
equals(LSWorkerHeartbeat that) |
boolean |
equals(Object that) |
LSWorkerHeartbeat._Fields |
fieldForId(int fieldId) |
Iterator<ExecutorInfo> |
get_executors_iterator() |
int |
get_executors_size() |
List<ExecutorInfo> |
get_executors() |
int |
get_port() |
int |
get_time_secs() |
String |
get_topology_id() |
Object |
getFieldValue(LSWorkerHeartbeat._Fields field) |
int |
hashCode() |
boolean |
is_set_executors()
Returns true if field executors is set (has been assigned a value) and false otherwise
|
boolean |
is_set_port()
Returns true if field port is set (has been assigned a value) and false otherwise
|
boolean |
is_set_time_secs()
Returns true if field time_secs is set (has been assigned a value) and false otherwise
|
boolean |
is_set_topology_id()
Returns true if field topology_id is set (has been assigned a value) and false otherwise
|
boolean |
isSet(LSWorkerHeartbeat._Fields field)
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
|
void |
read(org.apache.storm.thrift.protocol.TProtocol iprot) |
void |
set_executors_isSet(boolean value) |
void |
set_executors(List<ExecutorInfo> executors) |
void |
set_port_isSet(boolean value) |
void |
set_port(int port) |
void |
set_time_secs_isSet(boolean value) |
void |
set_time_secs(int time_secs) |
void |
set_topology_id_isSet(boolean value) |
void |
set_topology_id(String topology_id) |
void |
setFieldValue(LSWorkerHeartbeat._Fields field,
Object value) |
String |
toString() |
void |
unset_executors() |
void |
unset_port() |
void |
unset_time_secs() |
void |
unset_topology_id() |
void |
validate() |
void |
write(org.apache.storm.thrift.protocol.TProtocol oprot) |
public static final Map<LSWorkerHeartbeat._Fields,org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap
public LSWorkerHeartbeat()
public LSWorkerHeartbeat(int time_secs, String topology_id, List<ExecutorInfo> executors, int port)
public LSWorkerHeartbeat(LSWorkerHeartbeat other)
public LSWorkerHeartbeat deepCopy()
deepCopy
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public void clear()
clear
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public int get_time_secs()
public void set_time_secs(int time_secs)
public void unset_time_secs()
public boolean is_set_time_secs()
public void set_time_secs_isSet(boolean value)
public String get_topology_id()
public void set_topology_id(String topology_id)
public void unset_topology_id()
public boolean is_set_topology_id()
public void set_topology_id_isSet(boolean value)
public int get_executors_size()
public Iterator<ExecutorInfo> get_executors_iterator()
public void add_to_executors(ExecutorInfo elem)
public List<ExecutorInfo> get_executors()
public void set_executors(List<ExecutorInfo> executors)
public void unset_executors()
public boolean is_set_executors()
public void set_executors_isSet(boolean value)
public int get_port()
public void set_port(int port)
public void unset_port()
public boolean is_set_port()
public void set_port_isSet(boolean value)
public void setFieldValue(LSWorkerHeartbeat._Fields field, Object value)
setFieldValue
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public Object getFieldValue(LSWorkerHeartbeat._Fields field)
getFieldValue
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public boolean isSet(LSWorkerHeartbeat._Fields field)
isSet
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public boolean equals(LSWorkerHeartbeat that)
public int compareTo(LSWorkerHeartbeat other)
compareTo
in interface Comparable<LSWorkerHeartbeat>
public LSWorkerHeartbeat._Fields fieldForId(int fieldId)
fieldForId
in interface org.apache.storm.thrift.TBase<LSWorkerHeartbeat,LSWorkerHeartbeat._Fields>
public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException
read
in interface org.apache.storm.thrift.TSerializable
org.apache.storm.thrift.TException
public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException
write
in interface org.apache.storm.thrift.TSerializable
org.apache.storm.thrift.TException
public void validate() throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TException
Copyright © 2023 The Apache Software Foundation. All rights reserved.