format code

jeff-zou · Jun 26, 2024 · b2e7bf9 · b2e7bf9
1 parent ce8d2ad
commit b2e7bf9
Show file tree

Hide file tree

Showing 4 changed files with 34 additions and 15 deletions.
diff --git a/src/main/java/org/apache/flink/connector/jdbc/catalog/GenericInJdbcCatalog.java b/src/main/java/org/apache/flink/connector/jdbc/catalog/GenericInJdbcCatalog.java
@@ -18,10 +18,6 @@
 
 package org.apache.flink.connector.jdbc.catalog;
 
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-import static org.apache.flink.util.StringUtils.isNullOrWhitespaceOnly;
-
 import org.apache.flink.connector.jdbc.catalog.common.CatalogViewSerialize;
 import org.apache.flink.connector.jdbc.catalog.common.DesensitiveUtil;
 import org.apache.flink.connector.jdbc.catalog.common.EncryptUtil;
@@ -58,6 +54,10 @@
 import java.sql.*;
 import java.util.*;
 
+import static org.apache.flink.util.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+import static org.apache.flink.util.StringUtils.isNullOrWhitespaceOnly;
+
 /** A generic catalog implementation that holds all meta objects in jdbc with no cache. */
 public class GenericInJdbcCatalog extends AbstractCatalog {
 
@@ -520,10 +520,10 @@ public void createPartition(
             CatalogPartition partition,
             boolean ignoreIfExists)
             throws TableNotExistException,
-                    TableNotPartitionedException,
-                    PartitionSpecInvalidException,
-                    PartitionAlreadyExistsException,
-                    CatalogException {
+            TableNotPartitionedException,
+            PartitionSpecInvalidException,
+            PartitionAlreadyExistsException,
+            CatalogException {
         throw new UnsupportedOperationException();
     }
 
@@ -903,9 +903,9 @@ public List<CatalogPartitionSpec> listPartitions(ObjectPath tablePath)
     public List<CatalogPartitionSpec> listPartitions(
             ObjectPath tablePath, CatalogPartitionSpec partitionSpec)
             throws TableNotExistException,
-                    TableNotPartitionedException,
-                    PartitionSpecInvalidException,
-                    CatalogException {
+            TableNotPartitionedException,
+            PartitionSpecInvalidException,
+            CatalogException {
         return null;
     }
 

diff --git a/src/main/java/org/apache/flink/connector/jdbc/catalog/common/CatalogViewSerialize.java b/src/main/java/org/apache/flink/connector/jdbc/catalog/common/CatalogViewSerialize.java
@@ -1,3 +1,21 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package org.apache.flink.connector.jdbc.catalog.common;
 
 import org.apache.flink.table.api.Schema;

diff --git a/...ain/java/org/apache/flink/connector/jdbc/catalog/factory/GenericInJdbcCatalogFactory.java b/...ain/java/org/apache/flink/connector/jdbc/catalog/factory/GenericInJdbcCatalogFactory.java
@@ -18,9 +18,6 @@
 
 package org.apache.flink.connector.jdbc.catalog.factory;
 
-import static org.apache.flink.connector.jdbc.catalog.factory.GenericInJdbcCatalogFactoryOptions.*;
-import static org.apache.flink.table.factories.FactoryUtil.PROPERTY_VERSION;
-
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.connector.jdbc.catalog.GenericInJdbcCatalog;
 import org.apache.flink.table.catalog.Catalog;
@@ -32,6 +29,9 @@
 import java.util.HashSet;
 import java.util.Set;
 
+import static org.apache.flink.connector.jdbc.catalog.factory.GenericInJdbcCatalogFactoryOptions.*;
+import static org.apache.flink.table.factories.FactoryUtil.PROPERTY_VERSION;
+
 /** Factory for {@link GenericInJdbcCatalog}. */
 public class GenericInJdbcCatalogFactory implements CatalogFactory {
 

diff --git a/...a/org/apache/flink/connector/jdbc/catalog/factory/GenericInJdbcCatalogFactoryOptions.java b/...a/org/apache/flink/connector/jdbc/catalog/factory/GenericInJdbcCatalogFactoryOptions.java
@@ -48,5 +48,6 @@ public class GenericInJdbcCatalogFactoryOptions {
     public static final ConfigOption<String> SECRET_KEY =
             ConfigOptions.key("secret.key").stringType().noDefaultValue();
 
-    private GenericInJdbcCatalogFactoryOptions() {}
+    private GenericInJdbcCatalogFactoryOptions() {
+    }
 }