[flink-connector-aws] branch main updated: [FLINK-29688][Connectors/DynamoDB] Add test to detect changes in DynamoDB model (#22)

[da...@apache.org]

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

dannycranmer pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git


The following commit(s) were added to refs/heads/main by this push:
     new 4427bcd  [FLINK-29688][Connectors/DynamoDB] Add test to detect changes in DynamoDB model (#22)
4427bcd is described below

commit 4427bcdcb91505a2e1155e20b149e2f6e89d4b96
Author: Danny Cranmer <da...@apache.org>
AuthorDate: Mon Nov 14 14:42:44 2022 +0000

    [FLINK-29688][Connectors/DynamoDB] Add test to detect changes in DynamoDB model (#22)
---
 .../dynamodb/sink/DynamoDbWriteRequestTest.java    | 47 ++++++++++++++++++++++
 1 file changed, 47 insertions(+)

diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestTest.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestTest.java
new file mode 100644
index 0000000..49a8894
--- /dev/null
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestTest.java
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.connector.dynamodb.sink;
+
+import org.junit.jupiter.api.Test;
+import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.Modifier;
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class DynamoDbWriteRequestTest {
+
+    @Test
+    public void testAttributeValueExpectedFields() {
+        List<Field> fields =
+                Arrays.stream(AttributeValue.class.getDeclaredFields())
+                        .filter(field -> !Modifier.isStatic(field.getModifiers()))
+                        .collect(Collectors.toList());
+
+        assertThat(fields)
+                .as(
+                        "If this test fails the DynamoDB AWS SDK may have changed. "
+                                + "We need to check this, and update the DynamoDbWriterStateSerializer if required.")
+                .hasSize(11);
+    }
+}