Skip to content

Commit

Permalink
rename UfsUrl.getProto -> UfsUrl.toProto
Browse files Browse the repository at this point in the history
  • Loading branch information
YichuanSun committed Aug 14, 2023
1 parent 9d7631f commit c006f8c
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -238,7 +238,7 @@ public URIStatus getStatus(final UfsUrl ufsPath, final GetStatusPOptions options
throws AlluxioStatusException {
return retryRPC(() -> new URIStatus(GrpcUtils
.fromProto(mClient.getStatus(GetStatusPRequest.newBuilder()
.setUfsPath(ufsPath.getProto())
.setUfsPath(ufsPath.toProto())
.setOptions(options).build()).getFileInfo())),
RPC_LOG, "GetStatus", "path=%s,options=%s", ufsPath, options);
}
Expand Down Expand Up @@ -319,7 +319,7 @@ public List<URIStatus> listStatus(final UfsUrl ufsPath, final ListStatusPOptions
return retryRPC(() -> {
List<URIStatus> result = new ArrayList<>();
mClient.listStatus(ListStatusPRequest.newBuilder()
.setUfsPath(ufsPath.getProto()).setOptions(options).build())
.setUfsPath(ufsPath.toProto()).setOptions(options).build())
.forEachRemaining(
(pListStatusResponse) -> result.addAll(pListStatusResponse.getFileInfosList().stream()
.map((pFileInfo) -> new URIStatus(GrpcUtils.fromProto(pFileInfo)))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -211,7 +211,7 @@ public List<URIStatus> listStatus(UfsUrl ufsPath, ListStatusPOptions options)
List<URIStatus> result = new ArrayList<>();
client.get().listStatus(ListStatusPRequest.newBuilder()
.setPath(ufsPath.toString())
.setUfsPath(ufsPath.getProto())
.setUfsPath(ufsPath.toProto())
.setOptions(options).build())
.forEachRemaining(
(pListStatusResponse) -> result.addAll(pListStatusResponse.getFileInfosList().stream()
Expand Down

0 comments on commit c006f8c

Please sign in to comment.