fix fmt and rebase

Author: goldmedal

datafusion/expr/src/async_udf.rs

@@ -112,8 +112,8 @@ impl ScalarUDFImpl for AsyncScalarUDF {
         self.inner.signature()
     }
 
-    fn return_type(&self, _arg_types: &[DataType]) -> Result<DataType> {
-        self.inner.return_type(_arg_types)
+    fn return_type(&self, arg_types: &[DataType]) -> Result<DataType> {
+        self.inner.return_type(arg_types)
     }
 
     fn invoke_with_args(&self, _args: ScalarFunctionArgs) -> Result<ColumnarValue> {

datafusion/physical-expr/src/async_scalar_function.rs

@@ -198,12 +198,12 @@ impl PhysicalExpr for AsyncFuncExpr {
         self
     }
 
-    fn data_type(&self, _input_schema: &Schema) -> Result<DataType> {
-        self.func.data_type(_input_schema)
+    fn data_type(&self, input_schema: &Schema) -> Result<DataType> {
+        self.func.data_type(input_schema)
     }
 
-    fn nullable(&self, _input_schema: &Schema) -> Result<bool> {
-        self.func.nullable(_input_schema)
+    fn nullable(&self, input_schema: &Schema) -> Result<bool> {
+        self.func.nullable(input_schema)
     }
 
     fn evaluate(&self, _batch: &RecordBatch) -> Result<ColumnarValue> {
@@ -225,4 +225,8 @@ impl PhysicalExpr for AsyncFuncExpr {
             func: new_func,
         }))
     }
+
+    fn fmt_sql(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "{}", self.func)
+    }
 }