diff --git a/v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java b/v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java
index 6a0f9ae18c..a4fa4d2298 100644
--- a/v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java
+++ b/v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java
@@ -210,6 +210,8 @@ private static com.google.cloud.teleport.v2.ValueCaptureType mapValueCaptureType
         return com.google.cloud.teleport.v2.ValueCaptureType.OLD_AND_NEW_VALUES;
       case NEW_ROW:
         return com.google.cloud.teleport.v2.ValueCaptureType.NEW_ROW;
+      case NEW_ROW_AND_OLD_VALUES:
+        return com.google.cloud.teleport.v2.ValueCaptureType.NEW_ROW_AND_OLD_VALUES;
       default:
         return com.google.cloud.teleport.v2.ValueCaptureType.NEW_VALUES;
     }
diff --git a/v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc b/v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc
index 3ceeb2bc95..1f7e4d5b08 100644
--- a/v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc
+++ b/v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc
@@ -61,7 +61,7 @@
       "type" : {
         "name": "ValueCaptureType",
         "type": "enum",
-        "symbols": ["OLD_AND_NEW_VALUES", "NEW_ROW", "NEW_VALUES"]
+        "symbols": ["OLD_AND_NEW_VALUES", "NEW_ROW", "NEW_VALUES", "NEW_ROW_AND_OLD_VALUES"]
       }
     },
     { "name" : "numberOfRecordsInTransaction", "type" : "long"},
@@ -89,4 +89,4 @@
         {"name": "spannerInstanceId", "type": ["null", "string"], "default": null },
         {"name": "outputMessageMetadata", "type": ["null", "string"], "default": null }
     ]
-    }
\ No newline at end of file
+    }