Uses of Interface
alluxio.retry.RetryPolicy

Packages that use RetryPolicy

Package	Description
alluxio
alluxio.cli.fs.command.job
alluxio.client.block
alluxio.common
alluxio.master
alluxio.master.file.activesync
alluxio.master.job
alluxio.master.job.metrics
alluxio.master.job.tracker
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, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new client base with specified retry policy supplier.
AbstractJobMasterClient(MasterClientContext clientConf, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.
AbstractMasterClient(MasterClientContext clientConf, MasterSelectionPolicy selectionPolicy, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client without a specific address.
AbstractMasterClient(MasterClientContext clientConf, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client without a specific address.

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.client.block

Constructor parameters in alluxio.client.block with type arguments of type RetryPolicy

Constructor and Description
RetryHandlingBlockMasterClient(MasterClientContext conf, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicy) Creates a new block master client.

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.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, ServiceType serviceType)
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf, UserState userState, ServiceType serviceType)

Uses of RetryPolicy in alluxio.master.file.activesync

Methods in alluxio.master.file.activesync that return RetryPolicy

Modifier and Type	Method and Description
RetryPolicy	ActiveSyncManager.getRetryPolicy() Gets the retry policy.

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.master.job.metrics

Methods in alluxio.master.job.metrics with parameters of type RetryPolicy

Modifier and Type	Method and Description
static void	DistributedCmdMetrics.batchIncrementForCompleteStatusWithRetry(BatchedJobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for batch config for complete status.
static long	DistributedCmdMetrics.getFileSize(String filePath, FileSystem fileSystem, RetryPolicy retryPolicy) get file size for a given filePath, return 0 if exceeding retries.
static void	DistributedCmdMetrics.incrementForAllConfigsCompleteStatus(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for both batch and non-batch configs for COMPLETE status.
static void	DistributedCmdMetrics.incrementForCompleteStatusWithRetry(JobConfig config, FileSystem fileSystem, RetryPolicy retryPolicy) Increment for non-batch config for complete status.

Uses of RetryPolicy in alluxio.master.job.tracker

Fields in alluxio.master.job.tracker declared as RetryPolicy

Modifier and Type	Field and Description
protected RetryPolicy	CmdRunAttempt.mRetryPolicy

Constructors in alluxio.master.job.tracker with parameters of type RetryPolicy

Constructor and Description
CmdRunAttempt(RetryPolicy retryPolicy, JobMaster jobMaster)

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.defaultClientRetry() Gives a default ClientRetry based on config.
static RetryPolicy	RetryUtils.defaultWorkerMasterClientRetry()

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.
static <V> V	RetryUtils.retryCallable(String description, Callable<V> f, RetryPolicy policy) Notice we assume the exception with the method is retryable, so we are not wasting time here.

Uses of RetryPolicy in alluxio.underfs

Fields in alluxio.underfs with type parameters of type RetryPolicy

Modifier and Type	Field and Description
protected java.util.function.Supplier<RetryPolicy>	ObjectLowLevelOutputStream.mRetryPolicy The retry policy of this multipart upload.

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	BlockMasterSyncHelper.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.