util class for copy

Author: david-leifker

metadata-io/src/main/java/com/linkedin/metadata/entity/EntityServiceImpl.java

@@ -2533,13 +2533,9 @@ private UpdateAspectResult ingestAspectToLocalDB(
     if (previousValue != null
         && DataTemplateUtil.areEqual(previousValue, writeItem.getRecordTemplate())) {
 
-      SystemMetadata latestSystemMetadata = null;
-      try {
-        latestSystemMetadata =
-            new SystemMetadata(previousBatchAspect.getSystemMetadata().data().copy());
-      } catch (CloneNotSupportedException e) {
-        throw new RuntimeException(e);
-      }
+      SystemMetadata latestSystemMetadata =
+          GenericRecordUtils.copy(previousBatchAspect.getSystemMetadata(), SystemMetadata.class);
+
       latestSystemMetadata.setLastRunId(
           previousBatchAspect.getSystemMetadata().getRunId(), SetMode.REMOVE_IF_NULL);
       latestSystemMetadata.setLastObserved(

metadata-utils/src/main/java/com/linkedin/metadata/utils/GenericRecordUtils.java

@@ -4,6 +4,7 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import com.linkedin.common.urn.Urn;
 import com.linkedin.data.ByteString;
+import com.linkedin.data.DataMap;
 import com.linkedin.data.template.RecordTemplate;
 import com.linkedin.entity.Aspect;
 import com.linkedin.entity.EntityResponse;
@@ -13,6 +14,8 @@
 import com.linkedin.metadata.models.registry.EntityRegistry;
 import com.linkedin.mxe.GenericAspect;
 import com.linkedin.mxe.GenericPayload;
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
 import java.nio.charset.StandardCharsets;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -23,6 +26,22 @@ public class GenericRecordUtils {
 
   private GenericRecordUtils() {}
 
+  public static <T extends RecordTemplate> T copy(T input, Class<T> clazz) {
+    try {
+      if (input == null) {
+        return null;
+      }
+      Constructor<T> constructor = clazz.getConstructor(DataMap.class);
+      return constructor.newInstance(input.data().copy());
+    } catch (CloneNotSupportedException
+        | InvocationTargetException
+        | NoSuchMethodException
+        | InstantiationException
+        | IllegalAccessException e) {
+      throw new RuntimeException(e);
+    }
+  }
+
   /** Deserialize the given value into the aspect based on the input aspectSpec */
   @Nonnull
   public static RecordTemplate deserializeAspect(