diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
index 09338bb2ec..16a56c8a9f 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
+++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
@@ -57,8 +57,7 @@ protected boolean transform(DmlType dmlType, IDataLoaderContext context, String[
                 originalkeyValues = toMap(keyNames, keyValues);
             }
             for (TransformTable transformTable : tablesToTransform) {
-                TransformedData pk = getPrimaryKeyValues(transformTable,
-                        originalkeyValues);
+                TransformedData pk = getPrimaryKeyValues(transformTable, originalkeyValues);
                 TransformedData row = cache.lookupRow(pk);
                 if (row == null) {
                     row = pk;
@@ -135,6 +134,11 @@ protected void transform(TransformedData row, TransformColumn transformColumn,
         row.put(transformColumn.getTargetColumnName(), value, pk);
     }
 
+    @Override
+    public void earlyCommit(IDataLoader loader, IncomingBatch batch) {
+        batchComplete(loader, batch);
+    }
+
     public void batchComplete(IDataLoader loader, IncomingBatch batch) {
         IDataLoaderContext context = loader.getContext();
         TransformCache cache = getTransformCache(loader.getContext());
@@ -209,7 +213,7 @@ protected Map<String, String> toMap(String[] columnNames, String[] columnValues)
         }
         return map;
     }
-    
+
     @Override
     public boolean isHandlingMissingTable(DataLoaderContext context) {
         List<TransformTable> tablesToTransform = findTablesToTransform(context);
@@ -230,7 +234,7 @@ protected TransformedData lookupRow(TransformedData pk) {
             }
 
             return row;
-        }        
+        }
 
         protected void cacheRow(TransformedData row) {
             if (lookupRow(row) == null) {