(args: &[ColumnarValue])
| 83 | } |
| 84 | |
| 85 | pub fn spark_space(args: &[ColumnarValue]) -> Result<ColumnarValue> { |
| 86 | if args.len() != 1 { |
| 87 | return exec_err!("space function takes exactly one argument"); |
| 88 | } |
| 89 | match &args[0] { |
| 90 | ColumnarValue::Array(array) => { |
| 91 | let result = spark_space_array(array)?; |
| 92 | Ok(ColumnarValue::Array(result)) |
| 93 | } |
| 94 | ColumnarValue::Scalar(scalar) => { |
| 95 | let result = spark_space_scalar(scalar)?; |
| 96 | Ok(ColumnarValue::Scalar(result)) |
| 97 | } |
| 98 | } |
| 99 | } |
| 100 | |
| 101 | fn spark_space_array(array: &ArrayRef) -> Result<ArrayRef> { |
| 102 | match array.data_type() { |
searching dependent graphs…