From 32e550596f437f9d0d8b37c9b7997324cc95fa41 Mon Sep 17 00:00:00 2001 From: gaojun2048 Date: Wed, 2 Mar 2022 11:13:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0udf=E6=8F=92=E4=BB=B6?= =?UTF-8?q?=E5=8A=A0=E8=BD=BD=E6=97=A5=E5=BF=97=20(#3)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- datafusion/src/plugin/udf.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/datafusion/src/plugin/udf.rs b/datafusion/src/plugin/udf.rs index 7f223ee69570..0c61fc2b35b9 100644 --- a/datafusion/src/plugin/udf.rs +++ b/datafusion/src/plugin/udf.rs @@ -70,7 +70,9 @@ impl PluginRegistrar for UDFPluginManager { .unwrap() .iter() .try_for_each(|udf_name| { + println!("udf_name: {}", udf_name); if self.scalar_udfs.contains_key(udf_name) { + println!("udf_name exists"); Err(DataFusionError::IoError(io::Error::new( io::ErrorKind::Other, format!("udf name: {} already exists", udf_name), @@ -88,7 +90,9 @@ impl PluginRegistrar for UDFPluginManager { .unwrap() .iter() .try_for_each(|udaf_name| { + println!("udaf_name: {}", udaf_name); if self.aggregate_udfs.contains_key(udaf_name) { + println!("udaf_name exists"); Err(DataFusionError::IoError(io::Error::new( io::ErrorKind::Other, format!("udaf name: {} already exists", udaf_name),