Modifier and Type | Method and Description |
---|---|
protected ArchivedExecutionGraphStore |
ApplicationClusterEntryPoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
Constructor and Description |
---|
ApplicationDispatcherBootstrap(PackagedProgram application,
Collection<JobID> recoveredJobIds,
Configuration configuration,
DispatcherGateway dispatcherGateway,
ScheduledExecutor scheduledExecutor,
FatalErrorHandler errorHandler) |
EmbeddedJobClient(JobID jobId,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor,
Time rpcTimeout) |
Constructor and Description |
---|
EmbeddedExecutorFactory(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor)
Creates an
EmbeddedExecutorFactory . |
EmbeddedExecutorServiceLoader(Collection<JobID> submittedJobIds,
DispatcherGateway dispatcherGateway,
ScheduledExecutor retryExecutor)
Creates an
EmbeddedExecutorServiceLoader . |
Modifier and Type | Interface and Description |
---|---|
interface |
ComponentMainThreadExecutor
Interface for an executor that runs tasks in the main thread of an
RpcEndpoint . |
Modifier and Type | Class and Description |
---|---|
static class |
ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
Dummy implementation of ComponentMainThreadExecutor.
|
class |
ScheduledExecutorServiceAdapter
Adapter class for a
ScheduledExecutorService which shall be used as a ScheduledExecutor . |
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<T> |
FutureUtils.retrySuccessfulWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation,
Time retryDelay,
Deadline deadline,
java.util.function.Predicate<T> acceptancePredicate,
ScheduledExecutor scheduledExecutor)
Retry the given operation with the given delay in between successful completions where the
result does not match a given predicate.
|
static <T> CompletableFuture<T> |
FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation,
int retries,
Time retryDelay,
java.util.function.Predicate<Throwable> retryPredicate,
ScheduledExecutor scheduledExecutor)
Retry the given operation with the given delay in between failures.
|
static <T> CompletableFuture<T> |
FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation,
int retries,
Time retryDelay,
ScheduledExecutor scheduledExecutor)
Retry the given operation with the given delay in between failures.
|
static CompletableFuture<Void> |
FutureUtils.scheduleWithDelay(Runnable operation,
Time delay,
ScheduledExecutor scheduledExecutor)
Schedule the operation with the given delay.
|
static <T> CompletableFuture<T> |
FutureUtils.scheduleWithDelay(java.util.function.Supplier<T> operation,
Time delay,
ScheduledExecutor scheduledExecutor)
Schedule the operation with the given delay.
|
Modifier and Type | Class and Description |
---|---|
class |
ActorSystemScheduledExecutorAdapter
Adapter to use a
ActorSystem as a ScheduledExecutor . |
Modifier and Type | Method and Description |
---|---|
DispatcherBootstrap |
DispatcherBootstrapFactory.create(DispatcherGateway dispatcher,
ScheduledExecutor scheduledExecutor,
FatalErrorHandler errorHandler) |
Constructor and Description |
---|
FileArchivedExecutionGraphStore(File rootDir,
Time expirationTime,
int maximumCapacity,
long maximumCacheSizeBytes,
ScheduledExecutor scheduledExecutor,
org.apache.flink.shaded.guava18.com.google.common.base.Ticker ticker) |
Modifier and Type | Method and Description |
---|---|
protected abstract ArchivedExecutionGraphStore |
ClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
protected ArchivedExecutionGraphStore |
JobClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
protected ArchivedExecutionGraphStore |
SessionClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
RestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor)
Called by the ExecutionGraph to eventually trigger a full recovery.
|
CompletableFuture<Void> |
NoRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
CompletableFuture<Void> |
FailureRateRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
CompletableFuture<Void> |
ThrowingRestartStrategy.restart(RestartCallback restarter,
ScheduledExecutor executor) |
CompletableFuture<Void> |
FixedDelayRestartStrategy.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 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.
|
HeartbeatMonitor<O> |
HeartbeatMonitor.Factory.createHeartbeatMonitor(ResourceID resourceID,
HeartbeatTarget<O> heartbeatTarget,
ScheduledExecutor mainThreadExecutor,
HeartbeatListener<?,O> heartbeatListener,
long heartbeatTimeoutIntervalMs)
Create heartbeat monitor heartbeat monitor.
|
Constructor and Description |
---|
HeartbeatManagerImpl(long heartbeatTimeoutIntervalMs,
ResourceID ownResourceID,
HeartbeatListener<I,O> heartbeatListener,
ScheduledExecutor mainThreadExecutor,
org.slf4j.Logger log) |
HeartbeatManagerImpl(long heartbeatTimeoutIntervalMs,
ResourceID ownResourceID,
HeartbeatListener<I,O> heartbeatListener,
ScheduledExecutor mainThreadExecutor,
org.slf4j.Logger log,
HeartbeatMonitor.Factory<O> heartbeatMonitorFactory) |
Modifier and Type | Method and Description |
---|---|
static ResourceManagerRuntimeServices |
ResourceManagerRuntimeServices.fromConfiguration(ResourceManagerRuntimeServicesConfiguration configuration,
HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
SlotManagerMetricGroup slotManagerMetricGroup) |
Constructor and Description |
---|
JobLeaderIdService(HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
Time jobTimeout) |
Constructor and Description |
---|
SlotManagerImpl(ScheduledExecutor scheduledExecutor,
SlotManagerConfiguration slotManagerConfiguration,
SlotManagerMetricGroup slotManagerMetricGroup) |
Modifier and Type | Class and Description |
---|---|
protected static class |
RpcEndpoint.MainThreadExecutor
Executor which executes runnables in the main thread context.
|
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() |
Constructor and Description |
---|
YarnApplicationStatusMonitor(org.apache.hadoop.yarn.client.api.YarnClient yarnClient,
org.apache.hadoop.yarn.api.records.ApplicationId yarnApplicationId,
ScheduledExecutor scheduledExecutor) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.