Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
ExecutorStats |
ExecutorBeat.getStats() |
Constructor and Description |
---|
ExecutorBeat(int timeSecs,
int uptime,
ExecutorStats stats) |
Modifier and Type | Method and Description |
---|---|
ExecutorStats |
ExecutorStats.deepCopy() |
ExecutorStats |
ExecutorSummary.get_stats() |
Modifier and Type | Method and Description |
---|---|
Map<ExecutorInfo,ExecutorStats> |
ClusterWorkerHeartbeat.get_executor_stats() |
Modifier and Type | Method and Description |
---|---|
int |
ExecutorStats.compareTo(ExecutorStats other) |
boolean |
ExecutorStats.equals(ExecutorStats that) |
void |
ClusterWorkerHeartbeat.put_to_executor_stats(ExecutorInfo key,
ExecutorStats val) |
void |
ExecutorSummary.set_stats(ExecutorStats stats) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterWorkerHeartbeat.set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats) |
Constructor and Description |
---|
ExecutorStats(ExecutorStats other)
Performs a deep copy on other.
|
Constructor and Description |
---|
ClusterWorkerHeartbeat(String storm_id,
Map<ExecutorInfo,ExecutorStats> executor_stats,
int time_secs,
int uptime_secs) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.