We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0f12c7f commit ce9547cCopy full SHA for ce9547c
1 file changed
src/main/java/org/commoncrawl/whirlwind/Duck.java
@@ -154,7 +154,7 @@ private static List<String> getLocalParquetFiles(Path indexPath) throws IOExcept
154
System.exit(1);
155
}
156
157
- List<String> files = Files.list(indexPath).filter(p -> p.toString().endsWith(".parquet")).map(Path::toString)
+ List<String> files = Files.walk(indexPath).map(Path::toString).filter(string -> string.endsWith(".parquet"))
158
.collect(Collectors.toList());
159
160
if (files.isEmpty()) {
0 commit comments