public static class DynamoDBMapperConfig.DefaultBatchWriteRetryStrategy extends java.lang.Object implements DynamoDBMapperConfig.BatchWriteRetryStrategy
Modifier and Type | Field and Description |
---|---|
private static int |
DEFAULT_MAX_RETRY |
private static long |
MAX_BACKOFF_IN_MILLISECONDS |
private int |
maxRetry |
Constructor and Description |
---|
DefaultBatchWriteRetryStrategy()
Keep retrying until success, with default backoff.
|
DefaultBatchWriteRetryStrategy(int maxRetry) |
Modifier and Type | Method and Description |
---|---|
long |
getDelayBeforeRetryUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems,
int retriesAttempted)
Returns the delay (in milliseconds) before retrying on
UnprocessedItems.
|
int |
getMaxRetryOnUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batchWriteItemInput)
Returns the max number of retries to be performed if the service
returns UnprocessedItems in the response.
|
private static final long MAX_BACKOFF_IN_MILLISECONDS
private static final int DEFAULT_MAX_RETRY
private final int maxRetry
public DefaultBatchWriteRetryStrategy()
public DefaultBatchWriteRetryStrategy(int maxRetry)
public int getMaxRetryOnUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batchWriteItemInput)
DynamoDBMapperConfig.BatchWriteRetryStrategy
getMaxRetryOnUnprocessedItems
in interface DynamoDBMapperConfig.BatchWriteRetryStrategy
batchWriteItemInput
- the one batch of write requests that is being sent to the
BatchWriteItem API.public long getDelayBeforeRetryUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems, int retriesAttempted)
DynamoDBMapperConfig.BatchWriteRetryStrategy
getDelayBeforeRetryUnprocessedItems
in interface DynamoDBMapperConfig.BatchWriteRetryStrategy
unprocessedItems
- the UnprocessedItems returned by the service in the last
BatchWriteItem callretriesAttempted
- The number of times we have attempted to resend
UnprocessedItems.