You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@metamodel.apache.org by ka...@apache.org on 2019/02/26 06:17:52 UTC

[metamodel] 02/03: Added optional "region" property to factory

This is an automated email from the ASF dual-hosted git repository.

kaspersor pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/metamodel.git

commit c81437cd7a5fb1c4d92bfde5e3a610a37b5f5ff7
Author: Kasper Sørensen <i....@gmail.com>
AuthorDate: Fri Feb 15 21:32:27 2019 -0800

    Added optional "region" property to factory
---
 .../apache/metamodel/dynamodb/DynamoDbDataContextFactory.java  | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/dynamodb/src/main/java/org/apache/metamodel/dynamodb/DynamoDbDataContextFactory.java b/dynamodb/src/main/java/org/apache/metamodel/dynamodb/DynamoDbDataContextFactory.java
index 1e7273f..f9ce562 100644
--- a/dynamodb/src/main/java/org/apache/metamodel/dynamodb/DynamoDbDataContextFactory.java
+++ b/dynamodb/src/main/java/org/apache/metamodel/dynamodb/DynamoDbDataContextFactory.java
@@ -40,8 +40,14 @@ public class DynamoDbDataContextFactory extends AbstractDataContextFactory {
 
     @Override
     public DataContext create(DataContextProperties properties, ResourceFactoryRegistry resourceFactoryRegistry) {
-        final AmazonDynamoDB client =
-                AmazonDynamoDBClientBuilder.standard().withCredentials(getCredentials(properties)).build();
+        final AmazonDynamoDBClientBuilder clientBuilder =
+                AmazonDynamoDBClientBuilder.standard().withCredentials(getCredentials(properties));
+        final Object region = properties.toMap().get("region");
+        if (region != null && region instanceof String) {
+            clientBuilder.setRegion(region.toString());
+        }
+        
+        final AmazonDynamoDB client = clientBuilder.build();
         final SimpleTableDef[] tableDefs = properties.getTableDefs();
         return new DynamoDbDataContext(client, tableDefs);
     }