Package | Description |
---|---|
org.apache.flink.runtime.heartbeat |
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 . |
class |
NoOpHeartbeatManager<I,O>
HeartbeatManager implementation which does nothing. |
Modifier and Type | Method and Description |
---|---|
<I,O> HeartbeatManager<I,O> |
HeartbeatServices.createHeartbeatManager(ResourceID resourceId,
HeartbeatListener<I,O> heartbeatListener,
ScheduledExecutor mainThreadExecutor,
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 mainThreadExecutor,
org.slf4j.Logger log)
Creates a heartbeat manager which actively sends heartbeats to monitoring targets.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.