Skip to content

Commit

Permalink
format codestyle
Browse files Browse the repository at this point in the history
  • Loading branch information
JiamingMai committed Apr 24, 2024
1 parent 3e7526e commit ae34ab1
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,10 @@
*/
package io.trino.filesystem.alluxio;

import static java.util.Objects.requireNonNull;
import static org.assertj.core.api.Assertions.assertThat;

import alluxio.AlluxioURI;
import alluxio.client.file.FileSystem;
import alluxio.client.file.FileSystemContext;
import alluxio.exception.AlluxioException;

import io.trino.filesystem.AbstractTestTrinoFileSystem;
import io.trino.filesystem.Location;
import io.trino.filesystem.TrinoFileSystem;
Expand All @@ -31,6 +27,9 @@

import java.io.IOException;

import static java.util.Objects.requireNonNull;
import static org.assertj.core.api.Assertions.assertThat;

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public abstract class AbstractTestAlluxioFileSystem
extends AbstractTestTrinoFileSystem
Expand Down Expand Up @@ -58,7 +57,9 @@ protected void initialize()
}

@AfterAll
void tearDown() throws IOException {
void tearDown()
throws IOException
{
try {
fileSystem.deleteDirectory(rootLocation);
}
Expand All @@ -67,7 +68,6 @@ void tearDown() throws IOException {
alluxioFs = null;
rootLocation = null;
alluxioFileSystemFactory = null;

}
}

Expand Down Expand Up @@ -108,9 +108,11 @@ protected void verifyFileSystemIsEmpty()
AlluxioURI bucket = new AlluxioURI(rootLocation.path());
try {
assertThat(alluxioFs.listStatus(bucket)).isEmpty();
} catch (IOException e) {
}
catch (IOException e) {
throw new RuntimeException(e);
} catch (AlluxioException e) {
}
catch (AlluxioException e) {
throw new RuntimeException(e);
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,15 +13,15 @@
*/
package io.trino.filesystem.alluxio;

import static java.nio.charset.StandardCharsets.UTF_8;

import io.trino.filesystem.TrinoOutputFile;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;

import java.io.IOException;

import static java.nio.charset.StandardCharsets.UTF_8;

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class TestGcsFileSystemAlluxio
extends AbstractTestAlluxioFileSystem
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.trace.Tracer;
import io.trino.filesystem.TrinoFileSystemFactory;
import io.trino.filesystem.alluxio.AlluxioFileSystemCacheModule;
import io.trino.filesystem.alluxio.AlluxioFileSystemFactory;
import io.trino.filesystem.alluxio.AlluxioFileSystemModule;
import io.trino.filesystem.azure.AzureFileSystemFactory;
Expand All @@ -34,7 +35,6 @@
import io.trino.filesystem.cache.DefaultCacheKeyProvider;
import io.trino.filesystem.cache.DefaultCachingHostAddressProvider;
import io.trino.filesystem.cache.TrinoFileSystemCache;
import io.trino.filesystem.alluxio.AlluxioFileSystemCacheModule;
import io.trino.filesystem.gcs.GcsFileSystemFactory;
import io.trino.filesystem.gcs.GcsFileSystemModule;
import io.trino.filesystem.s3.S3FileSystemFactory;
Expand Down

0 comments on commit ae34ab1

Please sign in to comment.