Uses of Interface
org.apache.flink.runtime.heartbeat.HeartbeatManager

Packages that use HeartbeatManager

Package	Description
org.apache.flink.runtime.heartbeat

Uses of HeartbeatManager in org.apache.flink.runtime.heartbeat

Classes in org.apache.flink.runtime.heartbeat that implement HeartbeatManager

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.

Methods in org.apache.flink.runtime.heartbeat that return HeartbeatManager

Modifier and Type	Method and Description
<I,O> HeartbeatManager<I,O>	HeartbeatServices.createHeartbeatManager(ResourceID resourceId, HeartbeatListener<I,O> heartbeatListener, ScheduledExecutor scheduledExecutor, org.slf4j.Logger log) Creates a heartbeat manager which does not actively send heartbeats.
<I,O> HeartbeatManager<I,O>	HeartbeatServices.createHeartbeatManagerSender(ResourceID resourceId, HeartbeatListener<I,O> heartbeatListener, ScheduledExecutor scheduledExecutor, org.slf4j.Logger log) Creates a heartbeat manager which actively sends heartbeats to monitoring targets.