datafusion_python/expr/unnest_expr.rs
1// Licensed to the Apache Software Foundation (ASF) under one
2// or more contributor license agreements. See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership. The ASF licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License. You may obtain a copy of the License at
8//
9// http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied. See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18use std::fmt::{self, Display, Formatter};
19
20use datafusion::logical_expr::expr::Unnest;
21use pyo3::prelude::*;
22
23use super::PyExpr;
24
25#[pyclass(
26 from_py_object,
27 frozen,
28 name = "UnnestExpr",
29 module = "datafusion.expr",
30 subclass
31)]
32#[derive(Clone)]
33pub struct PyUnnestExpr {
34 unnest: Unnest,
35}
36
37impl From<Unnest> for PyUnnestExpr {
38 fn from(unnest: Unnest) -> PyUnnestExpr {
39 PyUnnestExpr { unnest }
40 }
41}
42
43impl From<PyUnnestExpr> for Unnest {
44 fn from(unnest: PyUnnestExpr) -> Self {
45 unnest.unnest
46 }
47}
48
49impl Display for PyUnnestExpr {
50 fn fmt(&self, f: &mut Formatter) -> fmt::Result {
51 write!(
52 f,
53 "Unnest
54 Expr: {:?}",
55 &self.unnest.expr,
56 )
57 }
58}
59
60#[pymethods]
61impl PyUnnestExpr {
62 /// Retrieves the expression that is being unnested
63 fn expr(&self) -> PyResult<PyExpr> {
64 Ok((*self.unnest.expr).clone().into())
65 }
66
67 fn __repr__(&self) -> PyResult<String> {
68 Ok(format!("UnnestExpr({self})"))
69 }
70
71 fn __name__(&self) -> PyResult<String> {
72 Ok("UnnestExpr".to_string())
73 }
74}