Modifier and Type | Method and Description |
---|---|
protected ExecutionGraphInfoStore |
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,
ClassLoader classLoader) |
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 | Method and Description |
---|---|
ScheduledExecutor |
CheckpointPlanCalculatorContext.getMainExecutor()
Acquires the main thread executor for this job.
|
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 <T> CompletableFuture<T> |
FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation,
RetryStrategy retryStrategy,
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,
RetryStrategy retryStrategy,
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 |
---|
FileExecutionGraphInfoStore(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 ExecutionGraphInfoStore |
JobClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
protected abstract ExecutionGraphInfoStore |
ClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
protected ExecutionGraphInfoStore |
SessionClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
Modifier and Type | Method and Description |
---|---|
ScheduledExecutor |
ExecutionGraphCheckpointPlanCalculatorContext.getMainExecutor() |
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 |
---|
DefaultJobLeaderIdService(HighAvailabilityServices highAvailabilityServices,
ScheduledExecutor scheduledExecutor,
Time jobTimeout) |
Modifier and Type | Method and Description |
---|---|
protected ScheduledExecutor |
AbstractResourceManagerDriver.getMainThreadExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractResourceManagerDriver.initialize(ResourceEventHandler<WorkerType> resourceEventHandler,
ScheduledExecutor mainThreadExecutor,
Executor ioExecutor) |
void |
ResourceManagerDriver.initialize(ResourceEventHandler<WorkerType> resourceEventHandler,
ScheduledExecutor mainThreadExecutor,
Executor ioExecutor)
Initialize the deployment specific components.
|
Constructor and Description |
---|
DeclarativeSlotManager(ScheduledExecutor scheduledExecutor,
SlotManagerConfiguration slotManagerConfiguration,
SlotManagerMetricGroup slotManagerMetricGroup,
ResourceTracker resourceTracker,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotTracker slotTracker) |
FineGrainedSlotManager(ScheduledExecutor scheduledExecutor,
SlotManagerConfiguration slotManagerConfiguration,
SlotManagerMetricGroup slotManagerMetricGroup,
ResourceTracker resourceTracker,
org.apache.flink.runtime.resourcemanager.slotmanager.TaskManagerTracker taskManagerTracker,
SlotStatusSyncer slotStatusSyncer,
ResourceAllocationStrategy resourceAllocationStrategy,
Time requirementCheckDelay) |
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–2022 The Apache Software Foundation. All rights reserved.