Qust Docs

表达式运算符 / expr.py

operator.r^

Python 运算符重载。

可执行示例returns: 未标注operator

输入 / 输出

输入

按下表列名和类型准备输入。

输入项类型示例
flagBooleanFalse
flag_bBooleanFalse

输出

项目说明
返回类型未标注
输出对象Expr；执行后得到 Polars DataFrame
输出语义输出列由算子、alias 或底层实现决定；需要稳定列名时显式使用 alias。
执行方式用 col(...).runtime() 或 col.with_cols(...).runtime() 创建执行计划后 calc_data。
核心调用col("flag_b") ^ col("flag")

打印输入 / 打印输出

下面内容来自本页示例代码真实执行后的 stdout，不是手写占位。

打印输入

print(data)
shape: (20, 2)
┌───────┬────────┐
│ flag  ┆ flag_b │
│ ---   ┆ ---    │
│ bool  ┆ bool   │
╞═══════╪════════╡
│ false ┆ false  │
│ false ┆ true   │
│ true  ┆ false  │
│ false ┆ false  │
│ false ┆ false  │
│ …     ┆ …      │
│ false ┆ false  │
│ false ┆ false  │
│ false ┆ false  │
│ true  ┆ false  │
│ false ┆ true   │
└───────┴────────┘

打印输出

print(out)
shape: (20, 1)
┌────────┐
│ flag_b │
│ ---    │
│ bool   │
╞════════╡
│ false  │
│ true   │
│ true   │
│ false  │
│ false  │
│ …      │
│ false  │
│ false  │
│ false  │
│ true   │
│ true   │
└────────┘

调用

Python
col("flag_b") ^ col("flag")
参数类型默认值说明
other未标注必填位置参数

完整代码

本页完整例子会执行真实的 calc_data 或对象调用。
展开可复制完整代码
Python
import datetime as dt
import polars as pl
import qust as qs
from qust import col, pms

data = pl.DataFrame(
    {
        "flag": [False, False, True, False, False, True, False, False, False, True, False, False, False, False, True, False, False, False, True, False],
        "flag_b": [False, True, False, False, False, True, False, False, False, False, True, False, False, False, True, False, False, False, False, True],
    }
)

print("算子:")
print('operator.r^')
print("场景:")
print('运算符重载：把 Python 运算符变成 Qust 表达式节点。')
print("模式:")
print('可执行示例：构造表达式并运行 calc_data。')
print("输入列:")
print('flag, flag_b')
print("调用:")
print('col("flag_b") ^ col("flag")')
print("输入数据:")
print(data)
expr = col("flag_b") ^ col("flag")
df = col(expr).runtime()
out = df.calc_data(data)
print("输出:")
print(out)

改成业务代码

改哪里怎么改
列名把示例 DataFrame 里的列名换成你的真实列名，列顺序保持和用法一致。
参数只改函数括号里的参数；不要随意改变 rolling/over/batch/select 的链式层级。
输出名需要稳定输出列名时，在表达式尾部加 .alias("name")。
调试先打印输入数据和调用字符串，再执行 calc_data；报 schema 错时先检查列数和 dtype。

注意事项

  • 先确认输入列名、顺序、类型和本页一致。
  • 输出列名不符合业务语义时，显式追加 .alias(...)。
  • 窗口和分组类算子要确认 rolling/expanding/over/batch 的链式层级。

来源

项目位置
源码文件expr.py
类/对象ExprNamespace