Package | Description |
---|---|
org.apache.storm.generated | |
org.apache.storm.stats |
Modifier and Type | Method and Description |
---|---|
WorkerSummary |
WorkerSummary.deepCopy() |
Modifier and Type | Method and Description |
---|---|
Iterator<WorkerSummary> |
SupervisorPageInfo.get_worker_summaries_iterator() |
List<WorkerSummary> |
SupervisorPageInfo.get_worker_summaries() |
Iterator<WorkerSummary> |
TopologyPageInfo.get_workers_iterator() |
List<WorkerSummary> |
TopologyPageInfo.get_workers() |
Modifier and Type | Method and Description |
---|---|
void |
SupervisorPageInfo.add_to_worker_summaries(WorkerSummary elem) |
void |
TopologyPageInfo.add_to_workers(WorkerSummary elem) |
int |
WorkerSummary.compareTo(WorkerSummary other) |
boolean |
WorkerSummary.equals(WorkerSummary that) |
Modifier and Type | Method and Description |
---|---|
void |
SupervisorPageInfo.set_worker_summaries(List<WorkerSummary> worker_summaries) |
void |
TopologyPageInfo.set_workers(List<WorkerSummary> workers) |
Constructor and Description |
---|
WorkerSummary(WorkerSummary other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
static List<WorkerSummary> |
StatsUtil.aggWorkerStats(String stormId,
String stormName,
Map<Integer,String> task2Component,
Map<List<Integer>,Map<String,Object>> beats,
Map<List<Long>,List<Object>> exec2NodePort,
Map<String,String> nodeHost,
Map<WorkerSlot,WorkerResources> worker2Resources,
boolean includeSys,
boolean userAuthorized,
String filterSupervisor,
String owner)
aggregate statistics per worker for a topology.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.