Modifier and Type | Method and Description |
---|---|
BatchWriteItemResult |
AmazonDynamoDBClient.batchWriteItem(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems) |
BatchWriteItemResult |
AmazonDynamoDB.batchWriteItem(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
Simplified method form for invoking the BatchWriteItem operation.
|
BatchWriteItemResult |
AbstractAmazonDynamoDB.batchWriteItem(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems) |
java.util.concurrent.Future<BatchWriteItemResult> |
AmazonDynamoDBAsyncClient.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
Simplified method form for invoking the BatchWriteItem operation.
|
java.util.concurrent.Future<BatchWriteItemResult> |
AmazonDynamoDBAsync.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
Simplified method form for invoking the BatchWriteItem operation.
|
java.util.concurrent.Future<BatchWriteItemResult> |
AbstractAmazonDynamoDBAsync.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
Simplified method form for invoking the BatchWriteItem operation.
|
java.util.concurrent.Future<BatchWriteItemResult> |
AmazonDynamoDBAsyncClient.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems,
AsyncHandler<BatchWriteItemRequest,BatchWriteItemResult> asyncHandler)
Simplified method form for invoking the BatchWriteItem operation with an
AsyncHandler.
|
java.util.concurrent.Future<BatchWriteItemResult> |
AmazonDynamoDBAsync.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems,
AsyncHandler<BatchWriteItemRequest,BatchWriteItemResult> asyncHandler)
Simplified method form for invoking the BatchWriteItem operation with an
AsyncHandler.
|
java.util.concurrent.Future<BatchWriteItemResult> |
AbstractAmazonDynamoDBAsync.batchWriteItemAsync(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems,
AsyncHandler<BatchWriteItemRequest,BatchWriteItemResult> asyncHandler)
Simplified method form for invoking the BatchWriteItem operation with an
AsyncHandler.
|
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
DynamoDBMapper.FailedBatch.unprocessedItems |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
DynamoDBMapper.FailedBatch.getUnprocessedItems() |
Modifier and Type | Method and Description |
---|---|
private void |
DynamoDBMapper.divideBatch(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> firstHalfBatch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> secondHalfBatch)
Divide the batch of objects to save into two smaller batches.
|
private void |
DynamoDBMapper.divideBatch(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> firstHalfBatch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> secondHalfBatch)
Divide the batch of objects to save into two smaller batches.
|
private void |
DynamoDBMapper.divideBatch(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> firstHalfBatch,
java.util.Map<java.lang.String,java.util.List<WriteRequest>> secondHalfBatch)
Divide the batch of objects to save into two smaller batches.
|
private DynamoDBMapper.FailedBatch |
DynamoDBMapper.doBatchWriteItemWithRetry(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batch,
DynamoDBMapperConfig.BatchWriteRetryStrategy batchWriteRetryStrategy)
Continue trying to process the batch and retry on UnproccessedItems as
according to the specified BatchWriteRetryStrategy
|
long |
DynamoDBMapperConfig.BatchWriteRetryStrategy.getDelayBeforeRetryUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems,
int retriesAttempted)
Returns the delay (in milliseconds) before retrying on
UnprocessedItems.
|
long |
DynamoDBMapperConfig.DefaultBatchWriteRetryStrategy.getDelayBeforeRetryUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems,
int retriesAttempted) |
int |
DynamoDBMapperConfig.BatchWriteRetryStrategy.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.
|
int |
DynamoDBMapperConfig.DefaultBatchWriteRetryStrategy.getMaxRetryOnUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batchWriteItemInput) |
void |
DynamoDBMapper.FailedBatch.setUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems) |
private java.util.List<DynamoDBMapper.FailedBatch> |
DynamoDBMapper.writeOneBatch(java.util.Map<java.lang.String,java.util.List<WriteRequest>> batch,
DynamoDBMapperConfig.BatchWriteRetryStrategy batchWriteRetryStrategy)
Process one batch of requests(max 25).
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemOutcome.getUnprocessedItems()
Convenient method to return the low-level unprocessed items.
|
Modifier and Type | Method and Description |
---|---|
BatchWriteItemOutcome |
DynamoDB.batchWriteItemUnprocessed(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems) |
Modifier and Type | Method and Description |
---|---|
BatchWriteItemOutcome |
BatchWriteItemApi.batchWriteItemUnprocessed(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems)
Used to perform a batch write operation for the unprocessed items
returned from a previous batch write operation.
|
Modifier and Type | Method and Description |
---|---|
BatchWriteItemOutcome |
BatchWriteItemImpl.batchWriteItemUnprocessed(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems) |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemSpec.unprocessedItems |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemSpec.getUnprocessedItems() |
Modifier and Type | Method and Description |
---|---|
BatchWriteItemSpec |
BatchWriteItemSpec.withUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems) |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemRequest.requestItems
A map of one or more table names and, for each table, a list of
operations to be performed (DeleteRequest or PutRequest).
|
private java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemResult.unprocessedItems
A map of tables and requests against those tables that were not
processed.
|
Modifier and Type | Method and Description |
---|---|
WriteRequest |
WriteRequest.clone() |
WriteRequest |
WriteRequest.withDeleteRequest(DeleteRequest deleteRequest)
A request to perform a DeleteItem operation.
|
WriteRequest |
WriteRequest.withPutRequest(PutRequest putRequest)
A request to perform a PutItem operation.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemRequest.getRequestItems()
A map of one or more table names and, for each table, a list of
operations to be performed (DeleteRequest or PutRequest).
|
java.util.Map<java.lang.String,java.util.List<WriteRequest>> |
BatchWriteItemResult.getUnprocessedItems()
A map of tables and requests against those tables that were not
processed.
|
Modifier and Type | Method and Description |
---|---|
BatchWriteItemRequest |
BatchWriteItemRequest.addRequestItemsEntry(java.lang.String key,
java.util.List<WriteRequest> value) |
BatchWriteItemResult |
BatchWriteItemResult.addUnprocessedItemsEntry(java.lang.String key,
java.util.List<WriteRequest> value) |
void |
BatchWriteItemRequest.setRequestItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
A map of one or more table names and, for each table, a list of
operations to be performed (DeleteRequest or PutRequest).
|
void |
BatchWriteItemResult.setUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems)
A map of tables and requests against those tables that were not
processed.
|
BatchWriteItemRequest |
BatchWriteItemRequest.withRequestItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
A map of one or more table names and, for each table, a list of
operations to be performed (DeleteRequest or PutRequest).
|
BatchWriteItemResult |
BatchWriteItemResult.withUnprocessedItems(java.util.Map<java.lang.String,java.util.List<WriteRequest>> unprocessedItems)
A map of tables and requests against those tables that were not
processed.
|
Constructor and Description |
---|
BatchWriteItemRequest(java.util.Map<java.lang.String,java.util.List<WriteRequest>> requestItems)
Constructs a new BatchWriteItemRequest object.
|
Modifier and Type | Method and Description |
---|---|
WriteRequest |
WriteRequestJsonUnmarshaller.unmarshall(JsonUnmarshallerContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WriteRequestJsonMarshaller.marshall(WriteRequest writeRequest,
StructuredJsonGenerator jsonGenerator)
Marshall the given parameter object, and output to a SdkJsonGenerator
|