Spotless Apply

DataLinkDC · Jan 30, 2024 · 0dac17a · 0dac17a
1 parent b060ce0
commit 0dac17a
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 11 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java
@@ -643,7 +643,11 @@ public Task initDefaultFlinkSQLEnv(Integer tenantId) {
                         + "'password' = '%s',\n"
                         + "    'url' = '%s'\n"
                         + ")%suse catalog my_catalog%s",
-                dsProperties.getUsername(), dsProperties.getPassword(), dsProperties.getUrl(), FlinkSQLConstant.SEPARATOR, FlinkSQLConstant.SEPARATOR);
+                dsProperties.getUsername(),
+                dsProperties.getPassword(),
+                dsProperties.getUrl(),
+                FlinkSQLConstant.SEPARATOR,
+                FlinkSQLConstant.SEPARATOR);
 
         if (null != defaultFlinkSQLEnvTask) {
             defaultFlinkSQLEnvTask.setStatement(sql);

diff --git a/dinky-common/src/main/java/org/dinky/utils/SqlUtil.java b/dinky-common/src/main/java/org/dinky/utils/SqlUtil.java
@@ -33,6 +33,7 @@ public class SqlUtil {
 
     private static final String SEMICOLON = ";";
     private static final String SQL_SEPARATOR = ";\\s*(?:\\n|--.*)";
+
     private SqlUtil() {}
 
     public static String[] getStatements(String sql) {

diff --git a/dinky-core/src/main/java/org/dinky/constant/FlinkSQLConstant.java b/dinky-core/src/main/java/org/dinky/constant/FlinkSQLConstant.java
@@ -19,8 +19,6 @@
 
 package org.dinky.constant;
 
-import org.dinky.data.model.SystemConfiguration;
-
 /**
  * FlinkSQLConstant
  *

diff --git a/dinky-core/src/main/java/org/dinky/explainer/Explainer.java b/dinky-core/src/main/java/org/dinky/explainer/Explainer.java
@@ -20,9 +20,7 @@
 package org.dinky.explainer;
 
 import org.dinky.assertion.Asserts;
-import org.dinky.constant.FlinkSQLConstant;
 import org.dinky.data.model.LineageRel;
-import org.dinky.data.model.SystemConfiguration;
 import org.dinky.data.result.ExplainResult;
 import org.dinky.data.result.SqlExplainResult;
 import org.dinky.executor.CustomTableEnvironment;
@@ -86,8 +84,7 @@ public Explainer(Executor executor, boolean useStatementSet, JobManager jobManag
         this.jobManager = jobManager;
     }
 
-    public static Explainer build(
-            Executor executor, boolean useStatementSet, JobManager jobManager) {
+    public static Explainer build(Executor executor, boolean useStatementSet, JobManager jobManager) {
         return new Explainer(executor, useStatementSet, jobManager);
     }
 

diff --git a/dinky-core/src/main/java/org/dinky/job/JobBuilder.java b/dinky-core/src/main/java/org/dinky/job/JobBuilder.java
@@ -19,7 +19,6 @@
 
 package org.dinky.job;
 
-import org.dinky.constant.FlinkSQLConstant;
 import org.dinky.executor.Executor;
 import org.dinky.gateway.enums.GatewayType;
 

diff --git a/dinky-core/src/main/java/org/dinky/job/JobManager.java b/dinky-core/src/main/java/org/dinky/job/JobManager.java
@@ -22,7 +22,6 @@
 import org.dinky.api.FlinkAPI;
 import org.dinky.assertion.Asserts;
 import org.dinky.classloader.DinkyClassLoader;
-import org.dinky.constant.FlinkSQLConstant;
 import org.dinky.context.CustomTableEnvironmentContext;
 import org.dinky.context.FlinkUdfPathContextHolder;
 import org.dinky.context.RowLevelPermissionsContext;
@@ -327,8 +326,8 @@ public JobResult executeSql(String statement) throws Exception {
         ready();
 
         DinkyClassLoaderUtil.initClassLoader(config, getDinkyClassLoader());
-        jobParam = Explainer.build(executor, useStatementSet, this)
-                .pretreatStatements(SqlUtil.getStatements(statement));
+        jobParam =
+                Explainer.build(executor, useStatementSet, this).pretreatStatements(SqlUtil.getStatements(statement));
         try {
             // step 1: init udf
             JobUDFBuilder.build(this).run();
-Original file line number
+Diff line change
@@ Expand Up / @@ -19,8 +19,6 @@ @@
     package org.dinky.constant;
-    import org.dinky.data.model.SystemConfiguration;
     /**
      * FlinkSQLConstant
      *
@@ Expand Down @@