Package | Description |
---|---|
org.apache.flink.runtime.heartbeat |
Modifier and Type | Class and Description |
---|---|
class |
HeartbeatMonitorImpl<O>
The default implementation of
HeartbeatMonitor . |
Modifier and Type | Method and Description |
---|---|
HeartbeatMonitor<O> |
HeartbeatMonitor.Factory.createHeartbeatMonitor(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget,
ScheduledExecutor mainThreadExecutor,
HeartbeatListener<?,O> heartbeatListener,
long heartbeatTimeoutIntervalMs,
int failedRpcRequestsUntilUnreachable)
Create heartbeat monitor heartbeat monitor.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.