public void initalize()

in src/main/java/com/netflix/bdp/s3mper/metastore/impl/DynamoDBMetastore.java [102:133]

• 21 lines of code
• 3 McCabe index (conditional complexity)

    public void initalize(URI uri, Configuration conf) throws Exception {
        scheme = uri.getScheme();
        
        String keyId = conf.get("fs."+uri.getScheme()+".awsAccessKeyId");
        String keySecret = conf.get("fs."+uri.getScheme()+".awsSecretAccessKey");
        
        //An override option for accessing across accounts
        keyId = conf.get("s3mper.override.awsAccessKeyId", keyId);
        keySecret = conf.get("s3mper.override.awsSecretAccessKey", keySecret);
        
        db = new AmazonDynamoDBClient(new BasicAWSCredentials(keyId, keySecret));
        
        readUnits = conf.getLong("s3mper.metastore.read.units", readUnits);
        writeUnits = conf.getLong("s3mper.metastore.write.units", writeUnits);
        
        retryCount = conf.getInt("s3mper.metastore.retry", retryCount);
        timeout = conf.getInt("s3mper.metastore.timeout", timeout);
        
        tableName = conf.get("s3mper.metastore.name", tableName);
        
        deleteMarkerEnabled = conf.getBoolean("s3mper.metastore.deleteMarker.enabled", false);
        
        boolean checkTableExists = conf.getBoolean("s3mper.metastore.create", false);
        
        if(checkTableExists) {
            ListTablesResult tables = db.listTables();
            
            if(!tables.getTableNames().contains(tableName)) {
                createTable();
            }
        }
    }