feat: introduce catalog api

Author: luoyuxia

crates/paimon/src/catalog/mod.rs

@@ -102,9 +102,9 @@ impl fmt::Debug for Identifier {
 
 use async_trait::async_trait;
 
-use crate::spec::SchemaChange;
-use crate::Result;
+use crate::spec::{Schema, SchemaChange};
 use crate::table::Table;
+use crate::Result;
 
 /// Catalog API for reading and writing metadata (databases, tables) in Paimon.
 ///
@@ -210,5 +210,3 @@ pub trait Catalog: Send + Sync {
         ignore_if_not_exists: bool,
     ) -> Result<()>;
 }
-
-

crates/paimon/src/error.rs

@@ -68,7 +68,6 @@ pub enum Error {
     FileIndexFormatInvalid { message: String },
 
     // ======================= catalog errors ===============================
-
     #[snafu(display("Database {} already exists.", database))]
     DatabaseAlreadyExist { database: String },
     #[snafu(display("Database {} does not exist.", database))]
@@ -80,15 +79,9 @@ pub enum Error {
     #[snafu(display("Table {} does not exist.", full_name))]
     TableNotExist { full_name: String },
     #[snafu(display("Column {} already exists in table {}.", column, full_name))]
-    ColumnAlreadyExist {
-        full_name: String,
-        column: String,
-    },
+    ColumnAlreadyExist { full_name: String, column: String },
     #[snafu(display("Column {} does not exist in table {}.", column, full_name))]
-    ColumnNotExist {
-        full_name: String,
-        column: String,
-    },
+    ColumnNotExist { full_name: String, column: String },
     #[snafu(display("Invalid identifier: {}", message))]
     IdentifierInvalid { message: String },
 }

crates/paimon/src/table.rs

@@ -17,10 +17,6 @@
 
 //! Table API for Apache Paimon
 
-use crate::io::FileIO;
-
 /// Table represents a table in the catalog.
 #[derive(Debug, Clone)]
-pub struct Table {
-    file_io: FileIO,
-}
+pub struct Table {}