Package | Description |
---|---|
org.apache.flink.runtime.dispatcher.cleanup | |
org.apache.flink.runtime.webmonitor.retriever.impl | |
org.apache.flink.util.concurrent |
Modifier and Type | Method and Description |
---|---|
RetryStrategy |
CleanupRetryStrategyFactory.createRetryStrategy(Configuration configuration)
Creates the
RetryStrategy instance based on the passed Configuration . |
Modifier and Type | Method and Description |
---|---|
static DefaultResourceCleaner.Builder<GloballyCleanableResource> |
DefaultResourceCleaner.forGloballyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor,
Executor cleanupExecutor,
RetryStrategy retryStrategy) |
static DefaultResourceCleaner.Builder<LocallyCleanableResource> |
DefaultResourceCleaner.forLocallyCleanableResources(ComponentMainThreadExecutor mainThreadExecutor,
Executor cleanupExecutor,
RetryStrategy retryStrategy) |
Constructor and Description |
---|
DispatcherResourceCleanerFactory(Executor cleanupExecutor,
RetryStrategy retryStrategy,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
JobGraphWriter jobGraphWriter,
BlobServer blobServer,
HighAvailabilityServices highAvailabilityServices,
JobManagerMetricGroup jobManagerMetricGroup) |
Constructor and Description |
---|
RpcGatewayRetriever(RpcService rpcService,
Class<T> gatewayType,
java.util.function.Function<UUID,F> fencingTokenMapper,
RetryStrategy retryStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
ExponentialBackoffRetryStrategy
An implementation of
RetryStrategy that retries that has an exponential backoff with a
cap. |
class |
FixedRetryStrategy
An implementation of
RetryStrategy that retries at a fixed delay. |
Modifier and Type | Method and Description |
---|---|
RetryStrategy |
RetryStrategy.getNextRetryStrategy() |
RetryStrategy |
ExponentialBackoffRetryStrategy.getNextRetryStrategy() |
RetryStrategy |
FixedRetryStrategy.getNextRetryStrategy() |
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.