public static String getDynamoDBEndpoint()

in emr-dynamodb-hadoop/src/main/java/org/apache/hadoop/dynamodb/DynamoDBUtil.java [231:255]

• 25 lines of code
• 7 McCabe index (conditional complexity)

  public static String getDynamoDBEndpoint(Configuration conf, String region) {
    String endpoint = getValueFromConf(conf, DynamoDBConstants.ENDPOINT);
    if (Strings.isNullOrEmpty(endpoint)) {
      if (Strings.isNullOrEmpty(region)) {
        region = getValueFromConf(conf, DynamoDBConstants.REGION);
      }
      if (Strings.isNullOrEmpty(region)) {
        region = getValueFromConf(conf, DynamoDBConstants.REGION_ID);
      }
      if (Strings.isNullOrEmpty(region)) {
        try {
          region = EC2MetadataUtils.getEC2InstanceRegion();
        } catch (Exception e) {
          log.warn(String.format("Exception when attempting to get AWS region information. Will "
              + "ignore and default " + "to %s", DynamoDBConstants.DEFAULT_AWS_REGION), e);
        }
      }
      if (Strings.isNullOrEmpty(region)) {
        region = DynamoDBConstants.DEFAULT_AWS_REGION;
      }
      endpoint = RegionUtils.getRegion(region).getServiceEndpoint(ServiceAbbreviations.Dynamodb);
    }
    log.info("Using endpoint for DynamoDB: " + endpoint);
    return endpoint;
  }