| Package | Description |
|---|---|
| backtype.storm.generated |
| Modifier and Type | Method and Description |
|---|---|
ExecutorInfo |
ExecutorInfo.deepCopy() |
ExecutorInfo |
ExecutorSummary.get_executor_info() |
| Modifier and Type | Method and Description |
|---|---|
Map<ExecutorInfo,ExecutorStats> |
ClusterWorkerHeartbeat.get_executor_stats() |
Iterator<ExecutorInfo> |
LSWorkerHeartbeat.get_executors_iterator() |
Iterator<ExecutorInfo> |
LocalAssignment.get_executors_iterator() |
List<ExecutorInfo> |
LSWorkerHeartbeat.get_executors() |
List<ExecutorInfo> |
LocalAssignment.get_executors() |
| Modifier and Type | Method and Description |
|---|---|
void |
LSWorkerHeartbeat.add_to_executors(ExecutorInfo elem) |
void |
LocalAssignment.add_to_executors(ExecutorInfo elem) |
int |
ExecutorInfo.compareTo(ExecutorInfo other) |
boolean |
ExecutorInfo.equals(ExecutorInfo that) |
void |
ClusterWorkerHeartbeat.put_to_executor_stats(ExecutorInfo key,
ExecutorStats val) |
void |
ExecutorSummary.set_executor_info(ExecutorInfo executor_info) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterWorkerHeartbeat.set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats) |
void |
LSWorkerHeartbeat.set_executors(List<ExecutorInfo> executors) |
void |
LocalAssignment.set_executors(List<ExecutorInfo> executors) |
| Constructor and Description |
|---|
ExecutorInfo(ExecutorInfo other)
Performs a deep copy on other.
|
ExecutorSummary(ExecutorInfo executor_info,
String component_id,
String host,
int port,
int uptime_secs) |
| Constructor and Description |
|---|
ClusterWorkerHeartbeat(String storm_id,
Map<ExecutorInfo,ExecutorStats> executor_stats,
int time_secs,
int uptime_secs) |
LocalAssignment(String topology_id,
List<ExecutorInfo> executors) |
LSWorkerHeartbeat(int time_secs,
String topology_id,
List<ExecutorInfo> executors,
int port) |
Copyright © 2015. All rights reserved.