Package software.amazon.awssdk.services.dynamodb.datamodeling

Class DynamoDbMapperConfig.DefaultBatchWriteRetryStrategy

java.lang.Object

software.amazon.awssdk.services.dynamodb.datamodeling.DynamoDbMapperConfig.DefaultBatchWriteRetryStrategy

All Implemented Interfaces:

DynamoDbMapperConfig.BatchWriteRetryStrategy

Enclosing class:

DynamoDbMapperConfig

public static class DynamoDbMapperConfig.DefaultBatchWriteRetryStrategy
extends Object
implements DynamoDbMapperConfig.BatchWriteRetryStrategy

The default BatchWriteRetryStrategy which always retries on UnprocessedItem up to a maximum number of times and use exponential backoff with random scale factor.

Field Summary

Fields

Modifier and Type	Field	Description
static DynamoDbMapperConfig.DefaultBatchWriteRetryStrategy	INSTANCE

Constructor Summary

Constructors

Constructor	Description
DefaultBatchWriteRetryStrategy()	Keep retrying until success, with default backoff.
DefaultBatchWriteRetryStrategy(int maxRetry)

Method Summary

Modifier and Type	Method	Description
DynamoDbMapperConfig	config()
long	getDelayBeforeRetryUnprocessedItems(Map<String,List<WriteRequest>> unprocessedItems, int retriesAttempted)	Returns the delay (in milliseconds) before retrying on UnprocessedItems.
int	maxRetryOnUnprocessedItems(Map<String,List<WriteRequest>> batchWriteItemInput)	Returns the max number of retries to be performed if the service returns UnprocessedItems in the response.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

public static final DynamoDbMapperConfig.DefaultBatchWriteRetryStrategy INSTANCE

Constructor Detail

DefaultBatchWriteRetryStrategy

public DefaultBatchWriteRetryStrategy()

Keep retrying until success, with default backoff.

DefaultBatchWriteRetryStrategy

public DefaultBatchWriteRetryStrategy(int maxRetry)

Method Detail

maxRetryOnUnprocessedItems

public int maxRetryOnUnprocessedItems(Map<String,List<WriteRequest>> batchWriteItemInput)

Description copied from interface: DynamoDbMapperConfig.BatchWriteRetryStrategy

Returns the max number of retries to be performed if the service returns UnprocessedItems in the response.

Specified by:

maxRetryOnUnprocessedItems in interface DynamoDbMapperConfig.BatchWriteRetryStrategy

Parameters:

batchWriteItemInput - the one batch of write requests that is being sent to the BatchWriteItem API.

Returns:

max number of retries to be performed if the service returns UnprocessedItems in the response, or a negative value if you want it to keep retrying until all the UnprocessedItems are fulfilled.

getDelayBeforeRetryUnprocessedItems

public long getDelayBeforeRetryUnprocessedItems(Map<String,List<WriteRequest>> unprocessedItems,
                                                int retriesAttempted)

Description copied from interface: DynamoDbMapperConfig.BatchWriteRetryStrategy

Returns the delay (in milliseconds) before retrying on UnprocessedItems.

Specified by:

getDelayBeforeRetryUnprocessedItems in interface DynamoDbMapperConfig.BatchWriteRetryStrategy

Parameters:

unprocessedItems - the UnprocessedItems returned by the service in the last BatchWriteItem call

retriesAttempted - The number of times we have attempted to resend UnprocessedItems.

Returns:

the delay (in milliseconds) before resending UnprocessedItems.

config

public final DynamoDbMapperConfig config()