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.