@@ -185,8 +185,7 @@ private void executeWrite(WriteOperation writeOperation) {
185185 * @param columnSchemaMapTransformer transforms columnSchemaMap entries during copy
186186 * @param writeOperation the write operation to execute on the new map copies
187187 */
188- private void executeWriteWithTransform (
189- ColumnSchemaMapTransformer columnSchemaMapTransformer , WriteOperation writeOperation ) {
188+ private void executeWriteWithTransform (ColumnSchemaMapTransformer columnSchemaMapTransformer ) {
190189 readWriteLock .writeLock ().lock ();
191190 isNotWrite .set (false );
192191 try {
@@ -198,9 +197,6 @@ private void executeWriteWithTransform(
198197 Map <String , Integer > newTagColumnIndexMap = new HashMap <>(tagColumnIndexMap );
199198 Map <String , Integer > newIdColumnIndexMap = new HashMap <>(idColumnIndexMap );
200199
201- // Execute write operation on local copies
202- writeOperation .execute (newColumnSchemaMap , newTagColumnIndexMap , newIdColumnIndexMap );
203-
204200 // After write completes, atomically update the class fields
205201 columnSchemaMap = newColumnSchemaMap ;
206202 tagColumnIndexMap = newTagColumnIndexMap ;
@@ -313,9 +309,6 @@ public void renameColumnSchema(final String oldName, final String newName) {
313309 } else {
314310 targetMap .put (key , schema );
315311 }
316- },
317- (colMap , tagMap , idMap ) -> {
318- // No additional operation needed, transformation already done during copy
319312 });
320313 }
321314
0 commit comments