Modifier and Type | Class and Description |
---|---|
class |
ScheduledExecutorServiceAdapter
Adapter class for a
ScheduledExecutorService which shall be used as a
ScheduledExecutor . |
Modifier and Type | Method and Description |
---|---|
void |
RestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor)
Called by the ExecutionGraph to eventually trigger a full recovery.
|
void |
NoRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
void |
FixedDelayRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
void |
FailureRateRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
static ResourceManagerRuntimeServices |
ResourceManagerRuntimeServices.fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration,
HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor) |
Constructor and Description |
---|
JobLeaderIdService(HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
Time jobTimeout) |
Constructor and Description |
---|
SlotManager(ScheduledExecutor scheduledExecutor,
Time taskManagerRequestTimeout,
Time slotRequestTimeout,
Time taskManagerTimeout) |
Modifier and Type | Method and Description |
---|---|
ScheduledExecutor |
RpcService.getScheduledExecutor()
Gets a scheduled executor from the RPC service.
|
Modifier and Type | Method and Description |
---|---|
ScheduledExecutor |
AkkaRpcService.getScheduledExecutor() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.