24
24
import java .util .stream .Collectors ;
25
25
import software .amazon .awssdk .annotations .SdkPublicApi ;
26
26
import software .amazon .awssdk .enhanced .dynamodb .DynamoDbEnhancedClient ;
27
- import software .amazon .awssdk .enhanced .dynamodb .DynamoDbTable ;
28
27
import software .amazon .awssdk .enhanced .dynamodb .Key ;
28
+ import software .amazon .awssdk .enhanced .dynamodb .MappedTableResource ;
29
29
import software .amazon .awssdk .enhanced .dynamodb .TableMetadata ;
30
30
import software .amazon .awssdk .enhanced .dynamodb .internal .operations .DefaultOperationContext ;
31
31
import software .amazon .awssdk .services .dynamodb .model .DeleteRequest ;
37
37
* {@link DynamoDbEnhancedClient#batchWriteItem(BatchWriteItemEnhancedRequest)}. The result describes any unprocessed items
38
38
* after the operation completes.
39
39
* <ul>
40
- * <li>Use the {@link #unprocessedPutItemsForTable(DynamoDbTable )} method once for each table present in the request
40
+ * <li>Use the {@link #unprocessedPutItemsForTable(MappedTableResource )} method once for each table present in the request
41
41
* to get any unprocessed items from a put action on that table.</li>
42
- * <li>Use the {@link #unprocessedDeleteItemsForTable(DynamoDbTable )} method once for each table present in the request
42
+ * <li>Use the {@link #unprocessedDeleteItemsForTable(MappedTableResource )} method once for each table present in the request
43
43
* to get any unprocessed items from a delete action on that table.</li>
44
44
* </ul>
45
45
*
@@ -67,7 +67,7 @@ public static Builder builder() {
67
67
* @param <T> the type of the table items
68
68
* @return a list of items
69
69
*/
70
- public <T > List <T > unprocessedPutItemsForTable (DynamoDbTable <T > mappedTable ) {
70
+ public <T > List <T > unprocessedPutItemsForTable (MappedTableResource <T > mappedTable ) {
71
71
List <WriteRequest > writeRequests =
72
72
unprocessedRequests .getOrDefault (mappedTable .tableName (),
73
73
Collections .emptyList ());
@@ -90,7 +90,7 @@ public <T> List<T> unprocessedPutItemsForTable(DynamoDbTable<T> mappedTable) {
90
90
* @param mappedTable the table to retrieve unprocessed items for.
91
91
* @return a list of keys that were not processed as part of the batch request.
92
92
*/
93
- public List <Key > unprocessedDeleteItemsForTable (DynamoDbTable <?> mappedTable ) {
93
+ public List <Key > unprocessedDeleteItemsForTable (MappedTableResource <?> mappedTable ) {
94
94
List <WriteRequest > writeRequests =
95
95
unprocessedRequests .getOrDefault (mappedTable .tableName (),
96
96
Collections .emptyList ());
0 commit comments