From 09758817eaea41ba9ad08e3e30a57fb34a2ff930 Mon Sep 17 00:00:00 2001 From: Jon Mease Date: Sat, 10 Aug 2024 13:56:55 -0400 Subject: [PATCH] cleanup --- vegafusion-runtime/src/expression/compiler/array.rs | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/vegafusion-runtime/src/expression/compiler/array.rs b/vegafusion-runtime/src/expression/compiler/array.rs index 0258a885..8766c2d4 100644 --- a/vegafusion-runtime/src/expression/compiler/array.rs +++ b/vegafusion-runtime/src/expression/compiler/array.rs @@ -1,8 +1,6 @@ -use std::sync::Arc; - use crate::expression::compiler::{compile, config::CompilationConfig}; -use datafusion_expr::{expr, Expr, ScalarFunctionDefinition, ScalarUDF}; -use datafusion_functions_array::make_array::MakeArray; +use datafusion_expr::Expr; +use datafusion_functions_array::expr_fn::make_array; use vegafusion_common::datafusion_common::DFSchema; use vegafusion_core::error::Result; use vegafusion_core::proto::gen::expression::ArrayExpression; @@ -17,9 +15,5 @@ pub fn compile_array( let phys_expr = compile(el, config, Some(schema))?; elements.push(phys_expr); } - - Ok(Expr::ScalarFunction(expr::ScalarFunction { - func_def: ScalarFunctionDefinition::UDF(Arc::new(ScalarUDF::from(MakeArray::new()))), - args: elements, - })) + Ok(make_array(elements)) }