datafusion_python/expr/binary_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 datafusion::logical_expr::BinaryExpr;
19use pyo3::prelude::*;
20
21use crate::expr::PyExpr;
22
23#[pyclass(frozen, name = "BinaryExpr", module = "datafusion.expr", subclass)]
24#[derive(Clone)]
25pub struct PyBinaryExpr {
26 expr: BinaryExpr,
27}
28
29impl From<PyBinaryExpr> for BinaryExpr {
30 fn from(expr: PyBinaryExpr) -> Self {
31 expr.expr
32 }
33}
34
35impl From<BinaryExpr> for PyBinaryExpr {
36 fn from(expr: BinaryExpr) -> PyBinaryExpr {
37 PyBinaryExpr { expr }
38 }
39}
40
41#[pymethods]
42impl PyBinaryExpr {
43 fn left(&self) -> PyExpr {
44 self.expr.left.as_ref().clone().into()
45 }
46
47 fn right(&self) -> PyExpr {
48 self.expr.right.as_ref().clone().into()
49 }
50
51 fn op(&self) -> String {
52 format!("{}", self.expr.op)
53 }
54
55 fn __repr__(&self) -> PyResult<String> {
56 Ok(format!("{}", self.expr))
57 }
58}