[connector] Support spark catalog and introduce some basic classes to support spark read and write

Author: Alibaba-HZY

…s/flink/utils/CatalogExceptionUtils.java …e/fluss/utils/CatalogExceptionUtils.javafluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/CatalogExceptionUtils.java renamed to fluss-common/src/main/java/org/apache/fluss/utils/CatalogExceptionUtils.java fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/CatalogExceptionUtils.java renamed to fluss-common/src/main/java/org/apache/fluss/utils/CatalogExceptionUtils.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.fluss.flink.utils;
+package org.apache.fluss.utils;
 
 import org.apache.fluss.exception.DatabaseAlreadyExistException;
 import org.apache.fluss.exception.DatabaseNotEmptyException;

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java

@@ -26,7 +26,6 @@
 import org.apache.fluss.exception.InvalidTableException;
 import org.apache.fluss.flink.lake.LakeCatalog;
 import org.apache.fluss.flink.procedure.ProcedureManager;
-import org.apache.fluss.flink.utils.CatalogExceptionUtils;
 import org.apache.fluss.flink.utils.DataLakeUtils;
 import org.apache.fluss.flink.utils.FlinkConversions;
 import org.apache.fluss.metadata.DatabaseDescriptor;
@@ -35,6 +34,7 @@
 import org.apache.fluss.metadata.TableDescriptor;
 import org.apache.fluss.metadata.TableInfo;
 import org.apache.fluss.metadata.TablePath;
+import org.apache.fluss.utils.CatalogExceptionUtils;
 import org.apache.fluss.utils.ExceptionUtils;
 import org.apache.fluss.utils.IOUtils;
 
@@ -82,13 +82,13 @@
 
 import static org.apache.flink.util.Preconditions.checkArgument;
 import static org.apache.fluss.config.ConfigOptions.BOOTSTRAP_SERVERS;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isPartitionAlreadyExists;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isPartitionInvalid;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isPartitionNotExist;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isTableInvalid;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isTableNotExist;
-import static org.apache.fluss.flink.utils.CatalogExceptionUtils.isTableNotPartitioned;
 import static org.apache.fluss.flink.utils.FlinkConversions.toFlussDatabase;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isPartitionAlreadyExists;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isPartitionInvalid;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isPartitionNotExist;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isTableInvalid;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isTableNotExist;
+import static org.apache.fluss.utils.CatalogExceptionUtils.isTableNotPartitioned;
 
 /**
  * A Flink Catalog for fluss.