transformation version

deephaven · Mar 7, 2025 · 22a74c0 · 22a74c0
1 parent ee07271
commit 22a74c0
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/TableUpdateValidator.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/TableUpdateValidator.java
@@ -55,6 +55,7 @@ public static TableUpdateValidator make(final String description, final QueryTab
 
     private TrackingWritableRowSet rowSet;
     private QueryTable resultTable;
+    private ModifiedColumnSet.Transformer mcsTransformer;
     private SharedContext sharedContext;
     private final String description;
 
@@ -108,7 +109,9 @@ public Result<QueryTable> initialize(boolean usePrev, long beforeClock) {
 
         resultTable = new QueryTable(tableToValidate.getDefinition(), rowSet,
                 new LinkedHashMap<>(tableToValidate.getColumnSourceMap()),
-                tableToValidate.getModifiedColumnSetForUpdates(), tableToValidate.getAttributes());
+                null,
+                tableToValidate.getAttributes());
+        mcsTransformer = tableToValidate .newModifiedColumnSetIdentityTransformer(resultTable);
 
         final TableUpdateListener listener;
         try (final SafeCloseable ignored1 = maybeOpenSharedContext();
@@ -222,7 +225,11 @@ private void onUpdate(final TableUpdate upstream) {
                 return;
             }
 
-            resultTable.notifyListeners(upstream.acquire());
+            final TableUpdateImpl downstream = TableUpdateImpl.copy(upstream);
+            downstream.modifiedColumnSet = resultTable.getModifiedColumnSetForUpdates();
+            mcsTransformer.clearAndTransform(upstream.modifiedColumnSet(), downstream.modifiedColumnSet);
+
+            resultTable.notifyListeners(downstream);
         }
     }