Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.generated | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
LSWorkerHeartbeat |
Container.readHeartbeat()
Read the Heartbeat for the current container.
|
protected LSWorkerHeartbeat |
SupervisorUtils.readWorkerHeartbeatImpl(Map<String,Object> conf,
String workerId) |
Modifier and Type | Method and Description |
---|---|
static Map<String,LSWorkerHeartbeat> |
SupervisorUtils.readWorkerHeartbeats(Map<String,Object> conf)
map from worker id to heartbeat
|
Map<String,LSWorkerHeartbeat> |
SupervisorUtils.readWorkerHeartbeatsImpl(Map<String,Object> conf) |
Modifier and Type | Method and Description |
---|---|
static boolean |
SupervisorUtils.isWorkerHbTimedOut(int now,
LSWorkerHeartbeat whb,
Map<String,Object> conf) |
Modifier and Type | Method and Description |
---|---|
LSWorkerHeartbeat |
LSWorkerHeartbeat.deepCopy() |
Modifier and Type | Method and Description |
---|---|
int |
LSWorkerHeartbeat.compareTo(LSWorkerHeartbeat other) |
boolean |
LSWorkerHeartbeat.equals(LSWorkerHeartbeat that) |
Constructor and Description |
---|
LSWorkerHeartbeat(LSWorkerHeartbeat other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
LSWorkerHeartbeat |
LocalState.getWorkerHeartBeat() |
Modifier and Type | Method and Description |
---|---|
void |
LocalState.setWorkerHeartBeat(LSWorkerHeartbeat workerHeartBeat) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.