Skip to content

Commit

Permalink
Minor cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
bchapuis committed May 29, 2024
1 parent 4aa28cc commit 04b1305
Showing 1 changed file with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -135,13 +135,9 @@ private Map<FileStatus, FileInfo> files() throws URISyntaxException {
return files;
}

public Stream<GeoParquetGroup> readParallel() throws IOException, URISyntaxException {
files();
Path globPath = new Path(uri.getPath());
URI rootUri = getRootUri(uri);
FileSystem fileSystem = FileSystem.get(rootUri, configuration);
public Stream<GeoParquetGroup> readParallel() throws URISyntaxException {
return StreamSupport.stream(
new GeoParquetGroupSpliterator(files),
new GeoParquetGroupSpliterator(files()),
true);
}

Expand Down

0 comments on commit 04b1305

Please sign in to comment.