chore: codefmt

Author: KKould

src/meta/proto-conv/tests/it/v158_udtf_server.rs

@@ -12,8 +12,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use std::collections::BTreeMap;
-
 use chrono::DateTime;
 use chrono::Utc;
 use databend_common_expression::types::DataType;

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -51,7 +51,7 @@ use databend_common_expression::Expr;
 use databend_common_expression::FunctionContext;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::FormatSettings;
-use databend_common_meta_app::principal::FileFormatParams;
+use databend_common_meta_app::principal::{FileFormatParams, UDTFServer};
 use databend_common_meta_app::principal::GrantObject;
 use databend_common_meta_app::principal::OnErrorMode;
 use databend_common_meta_app::principal::RoleInfo;
@@ -159,6 +159,8 @@ use databend_storages_common_table_meta::meta::TableSnapshot;
 use parking_lot::Mutex;
 use parking_lot::RwLock;
 use xorf::BinaryFuse16;
+use databend_common_catalog::table_args::TableArgs;
+use databend_common_catalog::table_function::TableFunction;
 
 type MetaType = (String, String, String);
 
@@ -488,6 +490,10 @@ impl Catalog for FakedCatalog {
     ) -> Result<GetAutoIncrementNextValueReply> {
         todo!()
     }
+
+    fn transform_udtf_as_table_function(&self, ctx: &dyn TableContext, table_args: &TableArgs, udtf: UDTFServer, func_name: &str) -> Result<Arc<dyn TableFunction>> {
+        todo!()
+    }
 }
 
 struct CtxDelegation {

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -50,7 +50,7 @@ use databend_common_expression::Expr;
 use databend_common_expression::FunctionContext;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::FormatSettings;
-use databend_common_meta_app::principal::FileFormatParams;
+use databend_common_meta_app::principal::{FileFormatParams, UDTFServer};
 use databend_common_meta_app::principal::GrantObject;
 use databend_common_meta_app::principal::OnErrorMode;
 use databend_common_meta_app::principal::RoleInfo;
@@ -164,6 +164,8 @@ use parking_lot::Mutex;
 use parking_lot::RwLock;
 use walkdir::WalkDir;
 use xorf::BinaryFuse16;
+use databend_common_catalog::table_args::TableArgs;
+use databend_common_catalog::table_function::TableFunction;
 
 #[tokio::test(flavor = "multi_thread")]
 async fn test_fuse_occ_retry() -> Result<()> {
@@ -1238,4 +1240,8 @@ impl Catalog for FakedCatalog {
     ) -> Result<GetAutoIncrementNextValueReply> {
         todo!()
     }
+
+    fn transform_udtf_as_table_function(&self, ctx: &dyn TableContext, table_args: &TableArgs, udtf: UDTFServer, func_name: &str) -> Result<Arc<dyn TableFunction>> {
+        todo!()
+    }
 }