Package | Description |
---|---|
org.apache.flink.runtime.heartbeat |
Modifier and Type | Interface and Description |
---|---|
interface |
HeartbeatManager<I,O>
A heartbeat manager has to be able to start/stop monitoring a
HeartbeatTarget , and report heartbeat timeouts
for this target. |
Modifier and Type | Class and Description |
---|---|
class |
HeartbeatManagerImpl<I,O>
Heartbeat manager implementation.
|
class |
HeartbeatManagerSenderImpl<I,O>
HeartbeatManager implementation which regularly requests a heartbeat response from
its monitored HeartbeatTarget . |
Modifier and Type | Method and Description |
---|---|
void |
HeartbeatManager.monitorTarget(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget)
Start monitoring a
HeartbeatTarget . |
void |
HeartbeatManagerImpl.monitorTarget(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.