Skip to content

Commit 0cf3627

Browse files
committed
Add most expr
1 parent f7951e3 commit 0cf3627

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

60 files changed

+138
-79
lines changed

src/expr/aggregate.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ use crate::errors::py_type_err;
2828
use crate::expr::PyExpr;
2929
use crate::sql::logical::PyLogicalPlan;
3030

31-
#[pyclass(name = "Aggregate", module = "datafusion.expr", subclass)]
31+
#[pyclass(frozen, name = "Aggregate", module = "datafusion.expr", subclass)]
3232
#[derive(Clone)]
3333
pub struct PyAggregate {
3434
aggregate: Aggregate,

src/expr/aggregate_expr.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,12 @@ use datafusion::logical_expr::expr::AggregateFunction;
2020
use pyo3::prelude::*;
2121
use std::fmt::{Display, Formatter};
2222

23-
#[pyclass(name = "AggregateFunction", module = "datafusion.expr", subclass)]
23+
#[pyclass(
24+
frozen,
25+
name = "AggregateFunction",
26+
module = "datafusion.expr",
27+
subclass
28+
)]
2429
#[derive(Clone)]
2530
pub struct PyAggregateFunction {
2631
aggr: AggregateFunction,

src/expr/alias.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use std::fmt::{self, Display, Formatter};
2121

2222
use datafusion::logical_expr::expr::Alias;
2323

24-
#[pyclass(name = "Alias", module = "datafusion.expr", subclass)]
24+
#[pyclass(frozen, name = "Alias", module = "datafusion.expr", subclass)]
2525
#[derive(Clone)]
2626
pub struct PyAlias {
2727
alias: Alias,

src/expr/analyze.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ use super::logical_node::LogicalNode;
2323
use crate::common::df_schema::PyDFSchema;
2424
use crate::sql::logical::PyLogicalPlan;
2525

26-
#[pyclass(name = "Analyze", module = "datafusion.expr", subclass)]
26+
#[pyclass(frozen, name = "Analyze", module = "datafusion.expr", subclass)]
2727
#[derive(Clone)]
2828
pub struct PyAnalyze {
2929
analyze: Analyze,

src/expr/between.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ use datafusion::logical_expr::expr::Between;
2020
use pyo3::prelude::*;
2121
use std::fmt::{self, Display, Formatter};
2222

23-
#[pyclass(name = "Between", module = "datafusion.expr", subclass)]
23+
#[pyclass(frozen, name = "Between", module = "datafusion.expr", subclass)]
2424
#[derive(Clone)]
2525
pub struct PyBetween {
2626
between: Between,

src/expr/binary_expr.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ use crate::expr::PyExpr;
1919
use datafusion::logical_expr::BinaryExpr;
2020
use pyo3::prelude::*;
2121

22-
#[pyclass(name = "BinaryExpr", module = "datafusion.expr", subclass)]
22+
#[pyclass(frozen, name = "BinaryExpr", module = "datafusion.expr", subclass)]
2323
#[derive(Clone)]
2424
pub struct PyBinaryExpr {
2525
expr: BinaryExpr,

src/expr/bool_expr.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use std::fmt::{self, Display, Formatter};
2121

2222
use super::PyExpr;
2323

24-
#[pyclass(name = "Not", module = "datafusion.expr", subclass)]
24+
#[pyclass(frozen, name = "Not", module = "datafusion.expr", subclass)]
2525
#[derive(Clone, Debug)]
2626
pub struct PyNot {
2727
expr: Expr,

src/expr/case.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ use crate::expr::PyExpr;
1919
use datafusion::logical_expr::Case;
2020
use pyo3::prelude::*;
2121

22-
#[pyclass(name = "Case", module = "datafusion.expr", subclass)]
22+
#[pyclass(frozen, name = "Case", module = "datafusion.expr", subclass)]
2323
#[derive(Clone)]
2424
pub struct PyCase {
2525
case: Case,

src/expr/cast.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ use crate::{common::data_type::PyDataType, expr::PyExpr};
1919
use datafusion::logical_expr::{Cast, TryCast};
2020
use pyo3::prelude::*;
2121

22-
#[pyclass(name = "Cast", module = "datafusion.expr", subclass)]
22+
#[pyclass(frozen, name = "Cast", module = "datafusion.expr", subclass)]
2323
#[derive(Clone)]
2424
pub struct PyCast {
2525
cast: Cast,

src/expr/column.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
use datafusion::common::Column;
1919
use pyo3::prelude::*;
2020

21-
#[pyclass(name = "Column", module = "datafusion.expr", subclass)]
21+
#[pyclass(frozen, name = "Column", module = "datafusion.expr", subclass)]
2222
#[derive(Clone)]
2323
pub struct PyColumn {
2424
pub col: Column,

0 commit comments

Comments
 (0)