| Package | Description | 
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.executor | |
| org.apache.storm.generated | |
| org.apache.storm.stats | 
| 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 | 
ExecutorShutdown.renderStats()  | 
ExecutorStats | 
IRunningExecutor.renderStats()  | 
| 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract ExecutorStats | 
CommonStats.renderStats()  | 
ExecutorStats | 
SpoutExecutorStats.renderStats()  | 
ExecutorStats | 
BoltExecutorStats.renderStats()  | 
static ExecutorStats | 
StatsUtil.thriftifyExecutorStats(Map stats)
Convert Executor stats to thrift data structure. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<List<Integer>,ExecutorStats> | 
StatsUtil.convertExecutorsStats(Map<ExecutorInfo,ExecutorStats> stats)
convert executors stats into a HashMap, note that ExecutorStats are remained unchanged. 
 | 
static Map<List<Integer>,ExecutorStats> | 
ClientStatsUtil.convertExecutorZkHbs(Map<List<Long>,ExecutorStats> executorBeats)
Convert Long Executor Ids in ZkHbs to Integer ones structure to java maps. 
 | 
static Map<List<Integer>,ExecutorStats> | 
ClientStatsUtil.mkEmptyExecutorZkHbs(Set<List<Long>> executors)
Make an map of executors to empty stats, in preparation for doing a heartbeat. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<String,Object> | 
StatsUtil.convertExecutorStats(ExecutorStats stats)
convert thrift ExecutorStats structure into a java HashMap. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<List<Integer>,ExecutorStats> | 
StatsUtil.convertExecutorsStats(Map<ExecutorInfo,ExecutorStats> stats)
convert executors stats into a HashMap, note that ExecutorStats are remained unchanged. 
 | 
static Map<List<Integer>,ExecutorStats> | 
ClientStatsUtil.convertExecutorZkHbs(Map<List<Long>,ExecutorStats> executorBeats)
Convert Long Executor Ids in ZkHbs to Integer ones structure to java maps. 
 | 
static Map<String,Object> | 
ClientStatsUtil.mkZkWorkerHb(String topoId,
            Map<List<Integer>,ExecutorStats> executorStats,
            Integer uptime)
Create a new worker heartbeat for zookeeper. 
 | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.