Skip to content

Commit

Permalink
implement new methods
Browse files Browse the repository at this point in the history
  • Loading branch information
the-other-tim-brown committed Jun 3, 2024
1 parent 427915c commit 5a90c7c
Showing 1 changed file with 12 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -111,6 +111,11 @@ public Stream<FileSlice> getLatestFileSlices(String partitionPath) {
return getView().getLatestFileSlices(partitionPath);
}

@Override
public Stream<FileSlice> getLatestFileSlicesIncludingInflight(String partitionPath) {
return Stream.empty();
}

@Override
public Stream<FileSlice> getLatestFileSlicesStateless(String partitionPath) {
return getView().getLatestFileSlicesStateless(partitionPath);
Expand Down Expand Up @@ -207,7 +212,12 @@ public Stream<Pair<HoodieFileGroupId, HoodieInstant>> getFileGroupsInPendingClus
}

@Override
public Void loadAllPartitions() {
return getView().loadAllPartitions();
public void loadAllPartitions() {
getView().loadAllPartitions();
}

@Override
public void loadPartitions(List<String> partitionPaths) {
getView().loadPartitions(partitionPaths);
}
}

0 comments on commit 5a90c7c

Please sign in to comment.