Skip to content

Commit

Permalink
[SMALLFIX] Import class type before code class
Browse files Browse the repository at this point in the history
### What changes are proposed in this pull request?

Import class type before code class

### Why are the changes needed?

Please clarify why the changes are needed. For instance,
1. If you propose a new API, clarify the use case for a new API.
2. If you fix a bug, describe the bug.

### Does this PR introduce any user facing changes?

Please list the user-facing changes introduced by your change, including
1. change in user-facing APIs
2. addition or removal of property keys
4. webui
No

pr-link: Alluxio#16768
change-id: cid-d72e58a4052542891dbc13844c23bb110886dbdd
  • Loading branch information
bzheng888 authored and jja725 committed Jan 27, 2023
1 parent f6e7978 commit fee0caa
Show file tree
Hide file tree
Showing 6 changed files with 19 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@
import alluxio.grpc.ListStatusPOptions;
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadMetadataPType;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand Down Expand Up @@ -80,6 +81,7 @@
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.function.Consumer;
import javax.annotation.concurrent.ThreadSafe;

Expand Down Expand Up @@ -535,7 +537,7 @@ public boolean stopLoad(AlluxioURI path) {

@Override
public String getLoadProgress(AlluxioURI path,
java.util.Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose) {
Optional<LoadProgressReportFormat> format, boolean verbose) {
try (CloseableResource<FileSystemMasterClient> client =
mFsContext.acquireMasterClientResource()) {
return client.get().getLoadProgress(path, format, verbose);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import alluxio.grpc.GetStatusPOptions;
import alluxio.grpc.ListStatusPOptions;
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand All @@ -45,6 +46,7 @@
import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.function.Consumer;

/**
Expand Down Expand Up @@ -254,7 +256,7 @@ public boolean stopLoad(AlluxioURI path) {

@Override
public String getLoadProgress(AlluxioURI path,
java.util.Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose) {
Optional<LoadProgressReportFormat> format, boolean verbose) {
return mDelegatedFileSystem.getLoadProgress(path, format, verbose);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadMetadataPOptions;
import alluxio.grpc.LoadMetadataPType;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand All @@ -67,6 +68,7 @@
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.Consumer;
import javax.security.auth.Subject;
Expand Down Expand Up @@ -764,5 +766,5 @@ boolean submitLoad(AlluxioURI path, java.util.OptionalLong bandwidth,
* @return the load job progress
*/
String getLoadProgress(AlluxioURI path,
java.util.Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose);
Optional<LoadProgressReportFormat> format, boolean verbose);
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@
import alluxio.grpc.GetStatusPOptions;
import alluxio.grpc.ListStatusPOptions;
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand Down Expand Up @@ -71,6 +72,8 @@
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.OptionalLong;
import java.util.function.Consumer;
import java.util.stream.Collectors;
import javax.annotation.concurrent.ThreadSafe;
Expand Down Expand Up @@ -393,7 +396,7 @@ public void needsSync(AlluxioURI path) throws IOException, AlluxioException {
}

@Override
public boolean submitLoad(AlluxioURI path, java.util.OptionalLong bandwidth,
public boolean submitLoad(AlluxioURI path, OptionalLong bandwidth,
boolean usePartialListing, boolean verify) {
throw new UnsupportedOperationException();
}
Expand All @@ -405,7 +408,7 @@ public boolean stopLoad(AlluxioURI path) {

@Override
public String getLoadProgress(AlluxioURI path,
java.util.Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose) {
Optional<LoadProgressReportFormat> format, boolean verbose) {
throw new UnsupportedOperationException();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
import alluxio.grpc.GetStatusPOptions;
import alluxio.grpc.ListStatusPOptions;
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand Down Expand Up @@ -81,6 +82,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Random;
import java.util.concurrent.ThreadLocalRandom;
import java.util.function.BiConsumer;
Expand Down Expand Up @@ -875,7 +877,7 @@ public boolean stopLoad(AlluxioURI path) {

@Override
public String getLoadProgress(AlluxioURI path,
java.util.Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose) {
Optional<LoadProgressReportFormat> format, boolean verbose) {
throw new UnsupportedOperationException();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@
import alluxio.grpc.GetStatusPOptions;
import alluxio.grpc.ListStatusPOptions;
import alluxio.grpc.ListStatusPartialPOptions;
import alluxio.grpc.LoadProgressReportFormat;
import alluxio.grpc.MountPOptions;
import alluxio.grpc.OpenFilePOptions;
import alluxio.grpc.RenamePOptions;
Expand Down Expand Up @@ -309,7 +310,7 @@ public boolean stopLoad(AlluxioURI path) {

@Override
public String getLoadProgress(AlluxioURI path,
Optional<alluxio.grpc.LoadProgressReportFormat> format, boolean verbose) {
Optional<LoadProgressReportFormat> format, boolean verbose) {
throw new UnsupportedOperationException();
}

Expand Down

0 comments on commit fee0caa

Please sign in to comment.