spotless.

s7monk · Dec 16, 2023 · 4bacb20 · 4bacb20
1 parent 49e8994
commit 4bacb20
Show file tree

Hide file tree

Showing 6 changed files with 28 additions and 28 deletions.
diff --git a/paimon-web-common/src/main/java/org/apache/paimon/web/common/executor/Executor.java b/paimon-web-common/src/main/java/org/apache/paimon/web/common/executor/Executor.java
@@ -22,8 +22,8 @@
 import org.apache.paimon.web.common.result.SubmissionResult;
 
 /**
- * The Executor interface provides methods to submit SQL statements for execution,
- * fetch results, and stop jobs.
+ * The Executor interface provides methods to submit SQL statements for execution, fetch results,
+ * and stop jobs.
  */
 public interface Executor {
 
@@ -46,23 +46,22 @@ public interface Executor {
     SubmissionResult fetchResults(FetchResultParams params) throws Exception;
 
     /**
-     * Stops the execution of a job with the given job ID. The method can accept
-     * additional options to customize the stopping behavior based on the
-     * underlying execution framework.
+     * Stops the execution of a job with the given job ID. The method can accept additional options
+     * to customize the stopping behavior based on the underlying execution framework.
      *
      * <p>For Flink, you can pass additional boolean flags:
+     *
      * <ul>
-     *   <li>{@code withSavepoint}: Set to {@code true} to create a savepoint before stopping.</li>
-     *   <li>{@code withDrain}: Set to {@code true} to perform a drain before stopping.</li>
+     *   <li>{@code withSavepoint}: Set to {@code true} to create a savepoint before stopping.
+     *   <li>{@code withDrain}: Set to {@code true} to perform a drain before stopping.
      * </ul>
-     * </p>
      *
-     * <p>For Spark, no additional options are required, and any supplied options will be ignored.</p>
+     * <p>For Spark, no additional options are required, and any supplied options will be ignored.
      *
      * @param jobId The unique ID of the job to stop.
-     * @param options Optional parameters to customize the stop behavior. The first boolean
-     *                is treated as {@code withSavepoint}, and the second boolean (if present)
-     *                is treated as {@code withDrain}.
+     * @param options Optional parameters to customize the stop behavior. The first boolean is
+     *     treated as {@code withSavepoint}, and the second boolean (if present) is treated as
+     *     {@code withDrain}.
      * @return {@code true} if the job was stopped successfully, {@code false} otherwise.
      * @throws Exception if there is an error stopping the job.
      */

diff --git a/paimon-web-common/src/main/java/org/apache/paimon/web/common/executor/ExecutorFactory.java b/paimon-web-common/src/main/java/org/apache/paimon/web/common/executor/ExecutorFactory.java
@@ -22,9 +22,8 @@
 public interface ExecutorFactory {
 
     /**
-     * Creates and returns a new instance of an {@link Executor}.
-     * Implementations should provide specific details about the type
-     * of executor being created and any initialization details.
+     * Creates and returns a new instance of an {@link Executor}. Implementations should provide
+     * specific details about the type of executor being created and any initialization details.
      *
      * @return A new instance of {@link Executor}.
      * @throws Exception if there is an error creating the executor instance.

diff --git a/paimon-web-common/src/main/java/org/apache/paimon/web/common/result/SubmissionResult.java b/paimon-web-common/src/main/java/org/apache/paimon/web/common/result/SubmissionResult.java
@@ -34,7 +34,12 @@ public class SubmissionResult implements Serializable {
     private final List<Map<String, Object>> data;
     private final boolean shouldFetchResult;
 
-    private SubmissionResult(String submitId, String jobId, String status, List<Map<String, Object>> data, boolean shouldFetchResult) {
+    private SubmissionResult(
+            String submitId,
+            String jobId,
+            String status,
+            List<Map<String, Object>> data,
+            boolean shouldFetchResult) {
         this.submitId = submitId;
         this.jobId = jobId;
         this.status = status;
@@ -107,6 +112,6 @@ public Builder shouldFetchResult(boolean shouldFetchResult) {
 
         public SubmissionResult build() {
             return new SubmissionResult(submitId, jobId, status, data, shouldFetchResult);
-    }
+        }
     }
 }
diff --git a/paimon-web-flink/src/main/java/org/apache/paimon/web/flink/executor/FlinkExecutor.java b/paimon-web-flink/src/main/java/org/apache/paimon/web/flink/executor/FlinkExecutor.java
@@ -134,7 +134,8 @@ private SubmissionResult buildResult(TableResult tableResult) throws Exception {
         return builder.build();
     }
 
-    private void setResult(TableResult tableResult, SubmissionResult.Builder builder) throws Exception {
+    private void setResult(TableResult tableResult, SubmissionResult.Builder builder)
+            throws Exception {
         Optional<JobClient> jobClient = tableResult.getJobClient();
         if (jobClient.isPresent()) {
             builder.jobId(jobClient.get().getJobID().toString());

diff --git a/...nk/src/main/java/org/apache/paimon/web/flink/sql/gateway/client/SqlGateWayRestClient.java b/...nk/src/main/java/org/apache/paimon/web/flink/sql/gateway/client/SqlGateWayRestClient.java
@@ -18,7 +18,6 @@
 
 package org.apache.paimon.web.flink.sql.gateway.client;
 
-
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.runtime.rest.FileUpload;
 import org.apache.flink.runtime.rest.RestClient;
@@ -33,9 +32,9 @@
 import org.apache.flink.util.concurrent.Executors;
 
 import java.io.IOException;
-import java.util.function.Supplier;
 import java.util.Collection;
 import java.util.concurrent.CompletableFuture;
+import java.util.function.Supplier;
 
 /** SQL gateway rest client. */
 public class SqlGateWayRestClient extends RestClient {
@@ -61,8 +60,7 @@ CompletableFuture<P> sendRequest(
                     Collection<FileUpload> fileUploads,
                     RestAPIVersion<? extends RestAPIVersion<?>> apiVersion) {
         return throwExceptionHandler(
-                () ->
-                {
+                () -> {
                     try {
                         return super.sendRequest(
                                 targetAddress,
@@ -85,8 +83,7 @@ CompletableFuture<P> sendRequest(
                     P extends ResponseBody>
             CompletableFuture<P> sendRequest(M messageHeaders, U messageParameters, R request) {
         return throwExceptionHandler(
-                () ->
-                {
+                () -> {
                     try {
                         return super.sendRequest(
                                 targetAddress,
@@ -111,8 +108,7 @@ CompletableFuture<P> sendRequest(
                     R request,
                     Collection<FileUpload> fileUploads) {
         return throwExceptionHandler(
-                () ->
-                {
+                () -> {
                     try {
                         return super.sendRequest(
                                 targetAddress,

diff --git a/...c/main/java/org/apache/paimon/web/flink/sql/gateway/executor/FlinkSqlGatewayExecutor.java b/...c/main/java/org/apache/paimon/web/flink/sql/gateway/executor/FlinkSqlGatewayExecutor.java
@@ -89,8 +89,8 @@ public SubmissionResult executeSql(String multiStatement) throws SqlExecutionExc
         return executeInsertStatements(insertStatements);
     }
 
-    private SubmissionResult executeDqlStatement(String statement, FlinkSqlOperationType operationType)
-            throws SqlExecutionException {
+    private SubmissionResult executeDqlStatement(
+            String statement, FlinkSqlOperationType operationType) throws SqlExecutionException {
         try {
             String operationId = client.executeStatement(session.getSessionId(), statement, null);
             FetchResultsResponseBody results =