Renamed endpoint_url to endpoint and getEndpointUrl() to getEndpointOverride() as requested in PR review

Author: amdhing

data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/ClientFactory.java

@@ -45,8 +45,8 @@ public DynamoDbStreamsClient buildDynamoDbStreamClient() {
                 .credentialsProvider(awsCredentialsProvider)
                 .region(awsAuthenticationConfig.getAwsRegion());
 
-        if (awsAuthenticationConfig.getEndpointUrl() != null && !awsAuthenticationConfig.getEndpointUrl().isEmpty()) {
-            clientBuilder.endpointOverride(URI.create(awsAuthenticationConfig.getEndpointUrl()));
+        if (awsAuthenticationConfig.getEndpointOverride() != null && !awsAuthenticationConfig.getEndpointOverride().isEmpty()) {
+            clientBuilder.endpointOverride(URI.create(awsAuthenticationConfig.getEndpointOverride()));
         }
 
         return clientBuilder.build();
@@ -58,8 +58,8 @@ public DynamoDbClient buildDynamoDBClient() {
                 .region(awsAuthenticationConfig.getAwsRegion())
                 .credentialsProvider(awsCredentialsProvider);
 
-        if (awsAuthenticationConfig.getEndpointUrl() != null && !awsAuthenticationConfig.getEndpointUrl().isEmpty()) {
-            clientBuilder.endpointOverride(URI.create(awsAuthenticationConfig.getEndpointUrl()));
+        if (awsAuthenticationConfig.getEndpointOverride() != null && !awsAuthenticationConfig.getEndpointOverride().isEmpty()) {
+            clientBuilder.endpointOverride(URI.create(awsAuthenticationConfig.getEndpointOverride()));
         }
 
         return clientBuilder.build();

data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/configuration/AwsAuthenticationConfig.java

@@ -29,9 +29,9 @@ public class AwsAuthenticationConfig {
     @Size(max = 5, message = "sts_header_overrides supports a maximum of 5 headers to override")
     private Map<String, String> awsStsHeaderOverrides;
 
-    @JsonProperty("endpoint_url")
-    @Size(min = 10, max = 2048, message = "endpoint_url length should be between 10 and 2048 characters")
-    private String endpoint_url;
+    @JsonProperty("endpoint")
+    @Size(min = 10, max = 2048, message = "endpoint length should be between 10 and 2048 characters")
+    private String endpoint;
 
     public String getAwsStsRoleArn() {
         return awsStsRoleArn;
@@ -49,8 +49,8 @@ public Map<String, String> getAwsStsHeaderOverrides() {
         return awsStsHeaderOverrides;
     }
 
-    public String getEndpointUrl() {
-        return endpoint_url;
+    public String getEndpointOverride() {
+        return endpoint;
     }
 }