commit f08a6721ab252f7d15c125e89fd59684bdac2bd1
author Ashvin Agrawal <ashvin@apache.org> Mon Feb 05 15:30:38 2024 -0800
committer Ashvin Agrawal <ashvin@apache.org> Wed Feb 07 10:27:22 2024 -0800
tree 6da5456f27e40f13cbeea59e2a4d5b18ef7b4e09
parent f8dcea2d7e39e7cdc463acc2e62f45d4c6b4fdfa

Restore previous file path mapping logic

core/src/main/java/io/onetable/filter/ToRelativePathFilter.java

diff --git a/core/src/main/java/io/onetable/filter/ToRelativePathFilter.java b/core/src/main/java/io/onetable/filter/ToRelativePathFilter.java
index 48bd5cf..3ba1f8c 100644
--- a/core/src/main/java/io/onetable/filter/ToRelativePathFilter.java
+++ b/core/src/main/java/io/onetable/filter/ToRelativePathFilter.java
@@ -24,6 +24,7 @@
 
 import com.google.auto.service.AutoService;
 import io.onetable.model.storage.OneDataFile;
+import io.onetable.paths.PathUtils;
 import io.onetable.spi.filter.SnapshotFilesFilter;
 
 /**
@@ -64,12 +65,11 @@
             .map(
                 file -> {
                   String oldPath = file.getPhysicalPath();
-                  if (!oldPath.startsWith(basePath)) {
+                  String newPath = PathUtils.getRelativePath(oldPath, basePath);
+                  if (oldPath.equals(newPath)) {
                     return file;
                   }
 
-                  String newPath = oldPath.substring(basePath.length() + 1);
-
                   // create a new data file
                   return OneDataFile.builder()
                       .schemaVersion(file.getSchemaVersion())