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

Packages that use HeartbeatListener

Package	Description
org.apache.flink.runtime.heartbeat

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

Methods in org.apache.flink.runtime.heartbeat with parameters of type HeartbeatListener

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.

Constructors in org.apache.flink.runtime.heartbeat with parameters of type HeartbeatListener

Constructor and Description
HeartbeatManagerImpl(long heartbeatTimeoutIntervalMs, ResourceID ownResourceID, HeartbeatListener<I,O> heartbeatListener, Executor executor, ScheduledExecutor scheduledExecutor, org.slf4j.Logger log)
HeartbeatManagerSenderImpl(long heartbeatPeriod, long heartbeatTimeout, ResourceID ownResourceID, HeartbeatListener<I,O> heartbeatListener, Executor executor, ScheduledExecutor scheduledExecutor, org.slf4j.Logger log)