lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3277] Filter non-parquet files in bootstrap procedure (#4639)

Browse Source
This commit is contained in:
wangxianghu
2022-01-19 21:13:51 +04:00
committed by GitHub
parent 7647562dad
commit db93ad2f4b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java
View File

@@ -70,7 +70,7 @@ public class BootstrapUtils {
Integer level = (int) relativePath.chars().filter(ch -> ch == '/').count(); Integer level = (int) relativePath.chars().filter(ch -> ch == '/').count();
HoodieFileStatus hoodieFileStatus = FileStatusUtils.fromFileStatus(topLevelStatus); HoodieFileStatus hoodieFileStatus = FileStatusUtils.fromFileStatus(topLevelStatus);
result.add(Pair.of(hoodieFileStatus, Pair.of(level, relativePath))); result.add(Pair.of(hoodieFileStatus, Pair.of(level, relativePath)));
} else if (metaPathFilter.accept(topLevelStatus.getPath())) { } else if (topLevelStatus.isDirectory() && metaPathFilter.accept(topLevelStatus.getPath())) {
subDirectories.add(topLevelStatus.getPath().toString()); subDirectories.add(topLevelStatus.getPath().toString());
} }
} }