参数 API / params.py
params.cast
live 参数 API。
可执行示例returns: 未标注params
输入 / 输出
输入
按下表列名和类型准备输入。
| 输入项 | 类型 | 示例 |
|---|---|---|
| 当前对象 | Expr / DataFrame / Params | 由调用链左侧对象提供 |
输出
| 项目 | 说明 |
|---|---|
| 返回类型 | 未标注 |
| 输出对象 | Python 对象 |
| 输出语义 | 输出列由算子、alias 或底层实现决定;需要稳定列名时显式使用 alias。 |
| 执行方式 | 直接调用并读取返回对象。 |
| 核心调用 | pms(2, 120).cast(pl.Float64) |
打印输入 / 打印输出
下面内容来自本页示例代码真实执行后的 stdout,不是手写占位。
打印输入
Params { inner: ParamsSliceUsize { title: "window", value: Mutex { data: 20, poisoned: false, .. }, start: 2, end: 120, step: Some(1) } }打印输出
shape: (4, 2) ┌──────────┬─────────────────────────────────┐ │ 项目 ┆ 内容 │ │ --- ┆ --- │ │ str ┆ str │ ╞══════════╪═════════════════════════════════╡ │ 返回类型 ┆ 未标注 │ │ 调用 ┆ pms(2, 120).cast(pl.Float64) │ │ 结果 ┆ 表达式构造完成 │ │ 查看表格 ┆ 放进 │ │ ┆ col(...).runtime().calc_dat… │ └──────────┴─────────────────────────────────┘
调用
pms(2, 120).cast(pl.Float64)| 参数 | 类型 | 默认值 | 说明 |
|---|---|---|---|
dtype | 未标注 | 必填 | 位置参数 |
完整代码
本页完整例子会执行真实的
calc_data 或对象调用。展开可复制完整代码
import polars as pl
import qust as qs
from qust import pms
print("算子:")
print('params.cast')
print("场景:")
print('参数:构造可联动 Monitor/Wasm 的 live 参数。')
print("模式:")
print('参数示例:打印 Params 链式调用结果。')
print("输入列:")
print('无固定表格输入列')
print("调用:")
print('pms(2, 120).cast(pl.Float64)')
param = pms(2, 120).title("window").value(20).step(1)
print("输入参数对象:")
print(param)
result = pms(2, 120).cast(pl.Float64)
print("输出:")
print(result)改成业务代码
| 改哪里 | 怎么改 |
|---|---|
| 列名 | 把示例 DataFrame 里的列名换成你的真实列名,列顺序保持和用法一致。 |
| 参数 | 只改函数括号里的参数;不要随意改变 rolling/over/batch/select 的链式层级。 |
| 输出名 | 需要稳定输出列名时,在表达式尾部加 .alias("name")。 |
| 调试 | 先打印输入数据和调用字符串,再执行 calc_data;报 schema 错时先检查列数和 dtype。 |
注意事项
- 先确认输入列名、顺序、类型和本页一致。
- 输出列名不符合业务语义时,显式追加
.alias(...)。 - 窗口和分组类算子要确认
rolling/expanding/over/batch的链式层级。
来源
| 项目 | 位置 |
|---|---|
| 源码文件 | params.py |
| 类/对象 | Params |