@Generated(value="Autogenerated by Thrift Compiler (0.13.0)") public class ClusterWorkerHeartbeat extends Object implements org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>, Serializable, Cloneable, Comparable<ClusterWorkerHeartbeat>
Modifier and Type | Class and Description |
---|---|
static class |
ClusterWorkerHeartbeat._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<ClusterWorkerHeartbeat._Fields,org.apache.storm.thrift.meta_data.FieldMetaData> |
metaDataMap |
Constructor and Description |
---|
ClusterWorkerHeartbeat() |
ClusterWorkerHeartbeat(ClusterWorkerHeartbeat other)
Performs a deep copy on other.
|
ClusterWorkerHeartbeat(String storm_id,
Map<ExecutorInfo,ExecutorStats> executor_stats,
int time_secs,
int uptime_secs) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
int |
compareTo(ClusterWorkerHeartbeat other) |
ClusterWorkerHeartbeat |
deepCopy() |
boolean |
equals(ClusterWorkerHeartbeat that) |
boolean |
equals(Object that) |
ClusterWorkerHeartbeat._Fields |
fieldForId(int fieldId) |
int |
get_executor_stats_size() |
Map<ExecutorInfo,ExecutorStats> |
get_executor_stats() |
String |
get_storm_id() |
int |
get_time_secs() |
int |
get_uptime_secs() |
Object |
getFieldValue(ClusterWorkerHeartbeat._Fields field) |
int |
hashCode() |
boolean |
is_set_executor_stats()
Returns true if field executor_stats is set (has been assigned a value) and false otherwise
|
boolean |
is_set_storm_id()
Returns true if field storm_id 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_uptime_secs()
Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
|
boolean |
isSet(ClusterWorkerHeartbeat._Fields field)
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
|
void |
put_to_executor_stats(ExecutorInfo key,
ExecutorStats val) |
void |
read(org.apache.storm.thrift.protocol.TProtocol iprot) |
void |
set_executor_stats_isSet(boolean value) |
void |
set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats) |
void |
set_storm_id_isSet(boolean value) |
void |
set_storm_id(String storm_id) |
void |
set_time_secs_isSet(boolean value) |
void |
set_time_secs(int time_secs) |
void |
set_uptime_secs_isSet(boolean value) |
void |
set_uptime_secs(int uptime_secs) |
void |
setFieldValue(ClusterWorkerHeartbeat._Fields field,
Object value) |
String |
toString() |
void |
unset_executor_stats() |
void |
unset_storm_id() |
void |
unset_time_secs() |
void |
unset_uptime_secs() |
void |
validate() |
void |
write(org.apache.storm.thrift.protocol.TProtocol oprot) |
public static final Map<ClusterWorkerHeartbeat._Fields,org.apache.storm.thrift.meta_data.FieldMetaData> metaDataMap
public ClusterWorkerHeartbeat()
public ClusterWorkerHeartbeat(String storm_id, Map<ExecutorInfo,ExecutorStats> executor_stats, int time_secs, int uptime_secs)
public ClusterWorkerHeartbeat(ClusterWorkerHeartbeat other)
Performs a deep copy on other.
public ClusterWorkerHeartbeat deepCopy()
deepCopy
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>
public void clear()
clear
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>
public String get_storm_id()
public void set_storm_id(String storm_id)
public void unset_storm_id()
public boolean is_set_storm_id()
Returns true if field storm_id is set (has been assigned a value) and false otherwise
public void set_storm_id_isSet(boolean value)
public int get_executor_stats_size()
public void put_to_executor_stats(ExecutorInfo key, ExecutorStats val)
public Map<ExecutorInfo,ExecutorStats> get_executor_stats()
public void set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats)
public void unset_executor_stats()
public boolean is_set_executor_stats()
Returns true if field executor_stats is set (has been assigned a value) and false otherwise
public void set_executor_stats_isSet(boolean value)
public int get_time_secs()
public void set_time_secs(int time_secs)
public void unset_time_secs()
public boolean is_set_time_secs()
Returns true if field time_secs is set (has been assigned a value) and false otherwise
public void set_time_secs_isSet(boolean value)
public int get_uptime_secs()
public void set_uptime_secs(int uptime_secs)
public void unset_uptime_secs()
public boolean is_set_uptime_secs()
Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
public void set_uptime_secs_isSet(boolean value)
public void setFieldValue(ClusterWorkerHeartbeat._Fields field, Object value)
setFieldValue
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>
public Object getFieldValue(ClusterWorkerHeartbeat._Fields field)
getFieldValue
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>
public boolean isSet(ClusterWorkerHeartbeat._Fields field)
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._Fields>
public boolean equals(ClusterWorkerHeartbeat that)
public int compareTo(ClusterWorkerHeartbeat other)
compareTo
in interface Comparable<ClusterWorkerHeartbeat>
public ClusterWorkerHeartbeat._Fields fieldForId(int fieldId)
fieldForId
in interface org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,ClusterWorkerHeartbeat._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 © 2022 The Apache Software Foundation. All rights reserved.