Uses of Interface
alluxio.retry.RetryPolicy

Packages that use RetryPolicy

Package	Description
alluxio
alluxio.cli.fs.command.job
alluxio.common
alluxio.hub.common
alluxio.master
alluxio.master.job
alluxio.proxy
alluxio.retry	Set of utilities for working with retryable operations.
alluxio.underfs
alluxio.underfs.cos
alluxio.underfs.gcs
alluxio.underfs.gcs.v2
alluxio.underfs.kodo
alluxio.underfs.obs
alluxio.underfs.oss
alluxio.underfs.s3a
alluxio.underfs.swift
alluxio.worker	Worker process and utils for working with the worker remotely.
alluxio.worker.block
alluxio.worker.job

Uses of RetryPolicy in alluxio

Methods in alluxio with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected <V> V	AbstractClient.retryRPC(RetryPolicy retryPolicy, AbstractClient.RpcCallable<V> rpc, org.slf4j.Logger logger, String rpcName, String description, Object... args)

Constructor parameters in alluxio with type arguments of type RetryPolicy

Constructor and Description
AbstractClient(ClientContext context, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new client base.
AbstractJobMasterClient(MasterClientContext clientConf, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.
AbstractMasterClient(MasterClientContext clientConf, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.

Uses of RetryPolicy in alluxio.cli.fs.command.job

Fields in alluxio.cli.fs.command.job declared as RetryPolicy

Modifier and Type	Field and Description
protected RetryPolicy	JobAttempt.mRetryPolicy

Constructors in alluxio.cli.fs.command.job with parameters of type RetryPolicy

Constructor and Description
JobAttempt(JobMasterClient client, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.common

Constructor parameters in alluxio.common with type arguments of type RetryPolicy

Constructor and Description
RpcPortHealthCheckClient(InetSocketAddress nodeAddress, ServiceType serviceType, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a worker health check client.

Uses of RetryPolicy in alluxio.hub.common

Constructor parameters in alluxio.hub.common with type arguments of type RetryPolicy

Constructor and Description
RpcClient(AlluxioConfiguration conf, InetSocketAddress connectAddress, java.util.function.Function<io.grpc.Channel,T> channelFactory, java.util.function.Supplier<RetryPolicy> policySupplier) Create a new instance of the RpcClient.

Uses of RetryPolicy in alluxio.master

Fields in alluxio.master with type parameters of type RetryPolicy

Modifier and Type	Field and Description
static java.util.function.Supplier<RetryPolicy>	AlluxioMasterMonitor.TWO_MIN_EXP_BACKOFF

Method parameters in alluxio.master with type arguments of type RetryPolicy

Modifier and Type	Method and Description
MasterHealthCheckClient.Builder	MasterHealthCheckClient.Builder.withRetryPolicy(java.util.function.Supplier<RetryPolicy> policySupplier)

Constructor parameters in alluxio.master with type arguments of type RetryPolicy

Constructor and Description
MasterHealthCheckClient(MasterHealthCheckClient.MasterType alluxioMasterType, boolean processCheck, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a new instance of MasterHealthCheckClient.
MasterServingHealthCheck(InetSocketAddress nodeAddress, ServiceType serviceType, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a new instance of MasterHealthCheckClient.MasterServingHealthCheck to check for an open RPC port for the given service.
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf)
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf, UserState userState)

Uses of RetryPolicy in alluxio.master.job

Constructor parameters in alluxio.master.job with type arguments of type RetryPolicy

Constructor and Description
JobMasterRpcHealthCheckClient(InetSocketAddress jobMasterAddress, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a job_master health check client.

Uses of RetryPolicy in alluxio.proxy

Constructor parameters in alluxio.proxy with type arguments of type RetryPolicy

Constructor and Description
ProxyHealthCheckClient(InetSocketAddress proxyAddress, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a proxy health check client.

Uses of RetryPolicy in alluxio.retry

Classes in alluxio.retry that implement RetryPolicy

Modifier and Type	Class and Description
class	CountingRetry An option which allows retrying based on maximum count.
class	ExponentialBackoffRetry Each retry will cause a sleep to happen.
class	ExponentialTimeBoundedRetry A retry policy which uses exponential backoff and a maximum duration time bound.
class	SleepingRetry A retry policy that uses thread sleeping for the delay.
class	TimeBoundedRetry Retry mechanism which performs retries until a certain period of time has elapsed.
class	TimeoutRetry A retry policy which allows retrying until a specified timeout is reached.

Methods in alluxio.retry that return RetryPolicy

Modifier and Type	Method and Description
static RetryPolicy	RetryUtils.defaultActiveSyncClientRetry(long activeUfsPollTimeoutMs)
static RetryPolicy	RetryUtils.defaultBlockReadRetry(java.time.Duration maxRetryDuration, java.time.Duration baseSleepMs, java.time.Duration maxSleepMs) Gives a ClientRetry based on the given parameters.
static RetryPolicy	RetryUtils.defaultClientRetry(java.time.Duration maxRetryDuration, java.time.Duration baseSleepMs, java.time.Duration maxSleepMs) Gives a ClientRetry based on the given parameters.
static RetryPolicy	RetryUtils.defaultFileWriteInitRetry(java.time.Duration maxRetryDuration, java.time.Duration baseSleepMs, java.time.Duration maxSleepMs) Gives a RetryPolicy for initialization of writing a file.
static RetryPolicy	RetryUtils.defaultMetricsClientRetry()
static RetryPolicy	RetryUtils.defaultWorkerMasterClientRetry(java.time.Duration workerMasterConnectRetryTimeout)
static RetryPolicy	RetryUtils.noRetryPolicy()

Methods in alluxio.retry with parameters of type RetryPolicy

Modifier and Type	Method and Description
static void	RetryUtils.retry(String action, RetryUtils.RunnableThrowsIOException f, RetryPolicy policy) Retries the given method until it doesn't throw an IO exception or the retry policy expires.

Uses of RetryPolicy in alluxio.underfs

Methods in alluxio.underfs with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected abstract InputStream	ObjectUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy) Internal function to open an input stream to an object.

Uses of RetryPolicy in alluxio.underfs.cos

Methods in alluxio.underfs.cos with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	COSUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.gcs

Methods in alluxio.underfs.gcs with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	GCSUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.gcs.v2

Methods in alluxio.underfs.gcs.v2 with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	GCSV2UnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.kodo

Methods in alluxio.underfs.kodo with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	KodoUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.obs

Methods in alluxio.underfs.obs with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	OBSUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.oss

Methods in alluxio.underfs.oss with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	OSSUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Uses of RetryPolicy in alluxio.underfs.s3a

Fields in alluxio.underfs.s3a declared as RetryPolicy

Modifier and Type	Field and Description
protected RetryPolicy	S3AInputStream.mRetryPolicy Policy determining the retry behavior in case the key does not exist.

Methods in alluxio.underfs.s3a with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	S3AUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Constructors in alluxio.underfs.s3a with parameters of type RetryPolicy

Constructor and Description
S3AInputStream(String bucketName, String key, com.amazonaws.services.s3.AmazonS3 client, long position, RetryPolicy retryPolicy) Constructor for an input stream of an object in s3 using the aws-sdk implementation to read the data.
S3AInputStream(String bucketName, String key, com.amazonaws.services.s3.AmazonS3 client, RetryPolicy retryPolicy) Constructor for an input stream of an object in s3 using the aws-sdk implementation to read the data.

Uses of RetryPolicy in alluxio.underfs.swift

Methods in alluxio.underfs.swift with parameters of type RetryPolicy

Modifier and Type	Method and Description
protected InputStream	SwiftUnderFileSystem.openObject(String key, OpenOptions options, RetryPolicy retryPolicy)

Constructors in alluxio.underfs.swift with parameters of type RetryPolicy

Constructor and Description
SwiftInputStream(org.javaswift.joss.model.Account account, String container, String object, long position, RetryPolicy retryPolicy, long multiRangeChunkSize) Constructor for an input stream to an object in a Swift API based store.
SwiftInputStream(org.javaswift.joss.model.Account account, String container, String object, RetryPolicy retryPolicy, long multiRangeChunkSize) Constructor for an input stream to an object in a Swift API based store.

Uses of RetryPolicy in alluxio.worker

Fields in alluxio.worker with type parameters of type RetryPolicy

Modifier and Type	Field and Description
static java.util.function.Supplier<RetryPolicy>	AlluxioWorkerMonitor.ONE_MIN_EXP_BACKOFF

Constructor parameters in alluxio.worker with type arguments of type RetryPolicy

Constructor and Description
WorkerHealthCheckClient(InetSocketAddress workerAddress, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a worker health check client.

Uses of RetryPolicy in alluxio.worker.block

Methods in alluxio.worker.block that return RetryPolicy

Modifier and Type	Method and Description
static RetryPolicy	BlockMasterSync.getDefaultAcquireLeaseRetryPolicy() Gets the default retry policy for acquiring a RegisterLease from the BlockMaster.

Methods in alluxio.worker.block with parameters of type RetryPolicy

Modifier and Type	Method and Description
void	BlockMasterClient.acquireRegisterLeaseWithBackoff(long workerId, int estimatedBlockCount, RetryPolicy retry) Acquires a RegisterLease from the master with the RetryPolicy specified.

Uses of RetryPolicy in alluxio.worker.job

Constructor parameters in alluxio.worker.job with type arguments of type RetryPolicy

Constructor and Description
JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf) Creates a worker health check client.