Skip to content

Commit 1a1eb6e

Browse files
bmaizelsbmaizels
committed
DDB-Enhanced: move previously internal OperationContext to public interface as it's already exposed in public extension interfaces
1 parent 7b4a1f2 commit 1a1eb6e

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

44 files changed

+146
-87
lines changed

‎.changes/next-release/bugfix-AmazonDynamoDBEnhancedClient-b37f4d2.json

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
{
2+
"type": "bugfix",
3+
"category": "Amazon DynamoDB Enhanced Client",
4+
"description": "Made OperationContext a public interface and moved it into public namespace as it was already exposed through another public interface. This will only impact extensions that have been written to reference the old internal-only class that should now switch to the approved stable public interface."
5+
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/DynamoDbExtensionContext.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
import java.util.Map;
1919
import software.amazon.awssdk.annotations.SdkPublicApi;
20-
import software.amazon.awssdk.enhanced.dynamodb.internal.operations.OperationContext;
2120
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
2221

2322
/**

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/OperationContext.java

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
/*
2+
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License").
5+
* You may not use this file except in compliance with the License.
6+
* A copy of the License is located at
7+
*
8+
* http://aws.amazon.com/apache2.0
9+
*
10+
* or in the "license" file accompanying this file. This file is distributed
11+
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
12+
* express or implied. See the License for the specific language governing
13+
* permissions and limitations under the License.
14+
*/
15+
16+
package software.amazon.awssdk.enhanced.dynamodb;
17+
18+
import software.amazon.awssdk.annotations.SdkPublicApi;
19+
20+
/**
21+
* A context object that is associated with a specific operation and identifies the resources that the operation is
22+
* meant to operate on.
23+
* <p>
24+
* This context is passed to and can be read by extension hooks (see {@link DynamoDbEnhancedClientExtension}).
25+
*/
26+
@SdkPublicApi
27+
public interface OperationContext {
28+
/**
29+
* The name of the table being operated on
30+
*/
31+
String tableName();
32+
33+
/**
34+
* The name of the index within the table being operated on. If it is the primary index, then this value will be
35+
* set to the constant {@link TableMetadata#primaryIndexName()}.
36+
*/
37+
String indexName();
38+
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/DefaultDocument.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
import software.amazon.awssdk.annotations.SdkInternalApi;
2222
import software.amazon.awssdk.enhanced.dynamodb.Document;
2323
import software.amazon.awssdk.enhanced.dynamodb.MappedTableResource;
24-
import software.amazon.awssdk.enhanced.dynamodb.internal.operations.OperationContext;
24+
import software.amazon.awssdk.enhanced.dynamodb.internal.operations.DefaultOperationContext;
2525
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
2626

2727
@SdkInternalApi
@@ -39,7 +39,7 @@ public static DefaultDocument create(Map<String, AttributeValue> itemMap) {
3939
public <T> T getItem(MappedTableResource<T> mappedTableResource) {
4040
return readAndTransformSingleItem(itemMap,
4141
mappedTableResource.tableSchema(),
42-
OperationContext.create(mappedTableResource.tableName()),
42+
DefaultOperationContext.create(mappedTableResource.tableName()),
4343
mappedTableResource.mapperExtension());
4444
}
4545

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/EnhancedClientUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@
2525
import software.amazon.awssdk.annotations.SdkInternalApi;
2626
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
2727
import software.amazon.awssdk.enhanced.dynamodb.Key;
28+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2829
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2930
import software.amazon.awssdk.enhanced.dynamodb.extensions.ReadModification;
3031
import software.amazon.awssdk.enhanced.dynamodb.internal.extensions.DefaultDynamoDbExtensionContext;
31-
import software.amazon.awssdk.enhanced.dynamodb.internal.operations.OperationContext;
3232
import software.amazon.awssdk.enhanced.dynamodb.model.Page;
3333
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
3434

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/extensions/DefaultDynamoDbExtensionContext.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,19 +19,20 @@
1919
import java.util.Objects;
2020
import software.amazon.awssdk.annotations.SdkInternalApi;
2121
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbExtensionContext;
22+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2223
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
23-
import software.amazon.awssdk.enhanced.dynamodb.internal.operations.OperationContext;
2424
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
2525

2626
/**
27-
* An SDK-internal implementation of {@link DynamoDbExtensionContext.BeforeWrite} and {@link DynamoDbExtensionContext.AfterRead}.
27+
* An SDK-internal implementation of {@link DynamoDbExtensionContext.BeforeWrite} and
28+
* {@link DynamoDbExtensionContext.AfterRead}.
2829
*/
2930
@SdkInternalApi
3031
public final class DefaultDynamoDbExtensionContext implements DynamoDbExtensionContext.BeforeWrite,
3132
DynamoDbExtensionContext.AfterRead {
32-
private Map<String, AttributeValue> items;
33-
private OperationContext operationContext;
34-
private TableMetadata tableMetadata;
33+
private final Map<String, AttributeValue> items;
34+
private final OperationContext operationContext;
35+
private final TableMetadata tableMetadata;
3536

3637
private DefaultDynamoDbExtensionContext(Builder builder) {
3738
this.items = builder.items;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/BatchableWriteOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import software.amazon.awssdk.annotations.SdkInternalApi;
1919
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
20+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2021
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2122
import software.amazon.awssdk.services.dynamodb.model.WriteRequest;
2223

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/CommonOperation.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,12 @@
2323
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
2424
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbIndex;
2525
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable;
26+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2627
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2728
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
2829
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
2930

31+
3032
/**
3133
* Common interface for a single operation that can be executed in a synchronous or non-blocking asynchronous fashion
3234
* against a mapped database table. These operations can be made against either the primary index of a table or a

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/CreateTableOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import java.util.stream.Collectors;
2828
import software.amazon.awssdk.annotations.SdkInternalApi;
2929
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
30+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
3031
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
3132
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
3233
import software.amazon.awssdk.enhanced.dynamodb.model.CreateTableEnhancedRequest;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/OperationContext.java renamed to ‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/DefaultOperationContext.java

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -16,30 +16,33 @@
1616
package software.amazon.awssdk.enhanced.dynamodb.internal.operations;
1717

1818
import software.amazon.awssdk.annotations.SdkInternalApi;
19+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
1920
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2021

2122
@SdkInternalApi
22-
public class OperationContext {
23+
public class DefaultOperationContext implements OperationContext {
2324
private final String tableName;
2425
private final String indexName;
2526

26-
private OperationContext(String tableName, String indexName) {
27+
private DefaultOperationContext(String tableName, String indexName) {
2728
this.tableName = tableName;
2829
this.indexName = indexName;
2930
}
3031

31-
public static OperationContext create(String tableName, String indexName) {
32-
return new OperationContext(tableName, indexName);
32+
public static DefaultOperationContext create(String tableName, String indexName) {
33+
return new DefaultOperationContext(tableName, indexName);
3334
}
3435

35-
public static OperationContext create(String tableName) {
36-
return new OperationContext(tableName, TableMetadata.primaryIndexName());
36+
public static DefaultOperationContext create(String tableName) {
37+
return new DefaultOperationContext(tableName, TableMetadata.primaryIndexName());
3738
}
3839

40+
@Override
3941
public String tableName() {
4042
return tableName;
4143
}
4244

45+
@Override
4346
public String indexName() {
4447
return indexName;
4548
}
@@ -53,7 +56,7 @@ public boolean equals(Object o) {
5356
return false;
5457
}
5558

56-
OperationContext that = (OperationContext) o;
59+
DefaultOperationContext that = (DefaultOperationContext) o;
5760

5861
if (tableName != null ? ! tableName.equals(that.tableName) : that.tableName != null) {
5962
return false;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/DeleteItemOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import java.util.function.Function;
2020
import software.amazon.awssdk.annotations.SdkInternalApi;
2121
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
22+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2223
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2324
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2425
import software.amazon.awssdk.enhanced.dynamodb.internal.EnhancedClientUtils;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/GetItemOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import software.amazon.awssdk.annotations.SdkInternalApi;
2121
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
2222
import software.amazon.awssdk.enhanced.dynamodb.Key;
23+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2324
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2425
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2526
import software.amazon.awssdk.enhanced.dynamodb.internal.EnhancedClientUtils;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/IndexOperation.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import java.util.concurrent.CompletableFuture;
1919
import software.amazon.awssdk.annotations.SdkInternalApi;
2020
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
21+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2122
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2223
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
2324
import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
@@ -56,7 +57,8 @@ default ResultT executeOnSecondaryIndex(TableSchema<ItemT> tableSchema,
5657
String indexName,
5758
DynamoDbEnhancedClientExtension extension,
5859
DynamoDbClient dynamoDbClient) {
59-
OperationContext context = OperationContext.create(tableName, indexName);
60+
OperationContext context =
61+
DefaultOperationContext.create(tableName, indexName);
6062
return execute(tableSchema, context, extension, dynamoDbClient);
6163
}
6264

@@ -79,7 +81,8 @@ default CompletableFuture<ResultT> executeOnSecondaryIndexAsync(TableSchema<Item
7981
String indexName,
8082
DynamoDbEnhancedClientExtension extension,
8183
DynamoDbAsyncClient dynamoDbAsyncClient) {
82-
OperationContext context = OperationContext.create(tableName, indexName);
84+
OperationContext context =
85+
DefaultOperationContext.create(tableName, indexName);
8386
return executeAsync(tableSchema, context, extension, dynamoDbAsyncClient);
8487
}
8588
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/PaginatedIndexOperation.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import software.amazon.awssdk.annotations.SdkInternalApi;
1919
import software.amazon.awssdk.core.async.SdkPublisher;
2020
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
21+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2122
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2223
import software.amazon.awssdk.enhanced.dynamodb.model.Page;
2324
import software.amazon.awssdk.enhanced.dynamodb.model.PageIterable;
@@ -58,7 +59,7 @@ default PageIterable<ItemT> executeOnSecondaryIndex(TableSchema<ItemT> tableSche
5859
String indexName,
5960
DynamoDbEnhancedClientExtension extension,
6061
DynamoDbClient dynamoDbClient) {
61-
OperationContext context = OperationContext.create(tableName, indexName);
62+
OperationContext context = DefaultOperationContext.create(tableName, indexName);
6263
return execute(tableSchema, context, extension, dynamoDbClient);
6364
}
6465

@@ -81,7 +82,7 @@ default SdkPublisher<Page<ItemT>> executeOnSecondaryIndexAsync(TableSchema<ItemT
8182
String indexName,
8283
DynamoDbEnhancedClientExtension extension,
8384
DynamoDbAsyncClient dynamoDbAsyncClient) {
84-
OperationContext context = OperationContext.create(tableName, indexName);
85+
OperationContext context = DefaultOperationContext.create(tableName, indexName);
8586
return executeAsync(tableSchema, context, extension, dynamoDbAsyncClient);
8687
}
8788
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/PaginatedOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
2525
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbIndex;
2626
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable;
27+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2728
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2829
import software.amazon.awssdk.enhanced.dynamodb.internal.TransformIterable;
2930
import software.amazon.awssdk.enhanced.dynamodb.model.Page;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/PaginatedTableOperation.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import software.amazon.awssdk.annotations.SdkInternalApi;
1919
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
20+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2021
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2122
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2223
import software.amazon.awssdk.enhanced.dynamodb.model.PageIterable;
@@ -57,7 +58,7 @@ default PageIterable<ItemT> executeOnPrimaryIndex(TableSchema<ItemT> tableSchema
5758
DynamoDbEnhancedClientExtension extension,
5859
DynamoDbClient dynamoDbClient) {
5960

60-
OperationContext context = OperationContext.create(tableName, TableMetadata.primaryIndexName());
61+
OperationContext context = DefaultOperationContext.create(tableName, TableMetadata.primaryIndexName());
6162
return execute(tableSchema, context, extension, dynamoDbClient);
6263
}
6364

@@ -78,7 +79,7 @@ default PagePublisher<ItemT> executeOnPrimaryIndexAsync(TableSchema<ItemT> table
7879
DynamoDbEnhancedClientExtension extension,
7980
DynamoDbAsyncClient dynamoDbAsyncClient) {
8081

81-
OperationContext context = OperationContext.create(tableName, TableMetadata.primaryIndexName());
82+
OperationContext context = DefaultOperationContext.create(tableName, TableMetadata.primaryIndexName());
8283
return executeAsync(tableSchema, context, extension, dynamoDbAsyncClient);
8384
}
8485
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/PutItemOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import software.amazon.awssdk.annotations.SdkInternalApi;
2222
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
2323
import software.amazon.awssdk.enhanced.dynamodb.Expression;
24+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2425
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2526
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2627
import software.amazon.awssdk.enhanced.dynamodb.extensions.WriteModification;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/QueryOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import software.amazon.awssdk.core.pagination.sync.SdkIterable;
2929
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
3030
import software.amazon.awssdk.enhanced.dynamodb.Expression;
31+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
3132
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
3233
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
3334
import software.amazon.awssdk.enhanced.dynamodb.internal.EnhancedClientUtils;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/ScanOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import software.amazon.awssdk.core.pagination.sync.SdkIterable;
2929
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
3030
import software.amazon.awssdk.enhanced.dynamodb.Expression;
31+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
3132
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
3233
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
3334
import software.amazon.awssdk.enhanced.dynamodb.internal.EnhancedClientUtils;

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/TableOperation.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import java.util.concurrent.CompletableFuture;
1919
import software.amazon.awssdk.annotations.SdkInternalApi;
2020
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
21+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2122
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
2223
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2324
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
@@ -54,7 +55,7 @@ default ResultT executeOnPrimaryIndex(TableSchema<ItemT> tableSchema,
5455
String tableName,
5556
DynamoDbEnhancedClientExtension extension,
5657
DynamoDbClient dynamoDbClient) {
57-
OperationContext context = OperationContext.create(tableName, TableMetadata.primaryIndexName());
58+
OperationContext context = DefaultOperationContext.create(tableName, TableMetadata.primaryIndexName());
5859
return execute(tableSchema, context, extension, dynamoDbClient);
5960
}
6061

@@ -76,7 +77,7 @@ default CompletableFuture<ResultT> executeOnPrimaryIndexAsync(TableSchema<ItemT>
7677
DynamoDbEnhancedClientExtension extension,
7778
DynamoDbAsyncClient dynamoDbAsyncClient) {
7879

79-
OperationContext context = OperationContext.create(tableName, TableMetadata.primaryIndexName());
80+
OperationContext context = DefaultOperationContext.create(tableName, TableMetadata.primaryIndexName());
8081
return executeAsync(tableSchema, context, extension, dynamoDbAsyncClient);
8182
}
8283
}

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/TransactableReadOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import software.amazon.awssdk.annotations.SdkInternalApi;
1919
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
20+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2021
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2122
import software.amazon.awssdk.services.dynamodb.model.TransactGetItem;
2223

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/TransactableWriteOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import software.amazon.awssdk.annotations.SdkInternalApi;
1919
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
20+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
2021
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
2122
import software.amazon.awssdk.services.dynamodb.model.TransactWriteItem;
2223

‎services-custom/dynamodb-enhanced/src/main/java/software/amazon/awssdk/enhanced/dynamodb/internal/operations/UpdateItemOperation.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import software.amazon.awssdk.annotations.SdkInternalApi;
3030
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClientExtension;
3131
import software.amazon.awssdk.enhanced.dynamodb.Expression;
32+
import software.amazon.awssdk.enhanced.dynamodb.OperationContext;
3233
import software.amazon.awssdk.enhanced.dynamodb.TableMetadata;
3334
import software.amazon.awssdk.enhanced.dynamodb.TableSchema;
3435
import software.amazon.awssdk.enhanced.dynamodb.extensions.WriteModification;

0 commit comments

Comments
 (0)