Namespace
expr
核心表达式方法，覆盖计算、窗口、过滤、元数据、多输入 join 和上下文。
100 个算子
算子输入 / 输出
| 算子 | 输入 | 输出 | 例子 |
|---|---|---|---|
expr.abs | x | 返回 Expr | 可执行 |
expr.add_suffix | x | 返回 Expr | 可执行 |
expr.alias | x | 返回 Expr | 可执行 |
expr.all | x | 返回 Expr | 可执行 |
expr.any | x | 返回 Expr | 可执行 |
expr.arg_max | x | 返回 Expr | 可执行 |
expr.arg_max_n | x | 返回 Expr | 可执行 |
expr.arg_min | x | 返回 Expr | 可执行 |
expr.arg_min_n | x | 返回 Expr | 可执行 |
expr.asof_join | 当前对象 | 返回 Expr | 接口 |
expr.attach_to_monitor | x, y | 返回 Expr | 接口 |
expr.batch_by | x, code | 返回 Expr | 接口 |
expr.cache | x | 返回 Expr | 可执行 |
expr.cast | x | 返回 Expr | 可执行 |
expr.cbrt | x | 返回 Expr | 可执行 |
expr.ceil | x | 返回 Expr | 可执行 |
expr.child_exprs | x, y | 返回 List[Expr] | 可执行 |
expr.clip | x | 返回 Expr | 可执行 |
expr.corr | x, y | 返回 Expr | 可执行 |
expr.count | x | 返回 Expr | 可执行 |
expr.count_last | flag | 返回 Expr | 可执行 |
expr.cov | a, b | 返回 Expr | 接口 |
expr.debug_runtime | x | 返回 未标注 | 可执行 |
expr.diff | x | 返回 Expr | 可执行 |
expr.dt | datetime | 返回 未标注 | 可执行 |
expr.eq_missing | x | 返回 未标注 | 可执行 |
expr.ewm | x | 返回 Expr | 可执行 |
expr.expanding | x | 返回 Expr | 可执行 |
expr.expanding_since | x, signal | 返回 Expr | 可执行 |
expr.ffill | x | 返回 Expr | 可执行 |
expr.fill_nan | x | 返回 Expr | 可执行 |
expr.fill_null | x | 返回 Expr | 可执行 |
expr.filter | x, signal | 返回 Expr | 接口 |
expr.filter_cb | x, signal | 返回 Expr | 可执行 |
expr.first_value | x | 返回 Expr | 可执行 |
expr.floor | x | 返回 Expr | 可执行 |
expr.get_by_index | price, open_sig, exit_sig | 返回 Expr | 接口 |
expr.get_metadata | x | 返回 dict[str, str] | 可执行 |
expr.get_metadata_value | x | 返回 str | None | 可执行 |
expr.group_by | x, code | 返回 Expr | 接口 |
expr.if_else | x | 返回 Expr | 可执行 |
expr.interval_join | 当前对象 | 返回 Expr | 接口 |
expr.is_between | x | 返回 Expr | 可执行 |
expr.is_finite | x | 返回 Expr | 可执行 |
expr.is_infinite | x | 返回 Expr | 可执行 |
expr.is_nan | x | 返回 Expr | 可执行 |
expr.is_not_nan | x | 返回 Expr | 可执行 |
expr.is_not_null | x | 返回 Expr | 可执行 |
expr.is_null | x | 返回 Expr | 可执行 |
expr.kurtosis | x | 返回 Expr | 可执行 |
expr.last_value | x | 返回 Expr | 可执行 |
expr.load | 当前对象 | 返回 未标注 | 可执行 |
expr.logical_and | flag | 返回 未标注 | 可执行 |
expr.logical_or | flag | 返回 未标注 | 可执行 |
expr.lookup_join | 当前对象 | 返回 Expr | 接口 |
expr.max | x | 返回 Expr | 可执行 |
expr.max_n | x | 返回 Expr | 可执行 |
expr.mean | x | 返回 Expr | 可执行 |
expr.median | x | 返回 Expr | 可执行 |
expr.min | x | 返回 Expr | 可执行 |
expr.min_n | x | 返回 Expr | 可执行 |
expr.ne_missing | x | 返回 未标注 | 可执行 |
expr.near | flag | 返回 Expr | 可执行 |
expr.over | x, code | 返回 Expr | 可执行 |
expr.pct | x | 返回 Expr | 可执行 |
expr.perf | x | 返回 Expr | 可执行 |
expr.pl | x | 返回 pl.Expr | 可执行 |
expr.pow | x | 返回 Expr | 可执行 |
expr.print | x | 返回 Expr | 可执行 |
expr.private | x | 返回 Expr | 可执行 |
expr.projection_name | x | 返回 str | None | 可执行 |
expr.quantile | x | 返回 Expr | 可执行 |
expr.rank | x | 返回 Expr | 可执行 |
expr.remote | x | 返回 未标注 | 接口 |
expr.rolling | x | 返回 Expr | 可执行 |
expr.rolling_dynamic | x, n | 返回 Expr | 可执行 |
expr.rolling_intra_day | x, signal, n | 返回 Expr | 接口 |
expr.round | x | 返回 Expr | 可执行 |
expr.runtime | x | 返回 未标注 | 可执行 |
expr.save | x | 返回 未标注 | 可执行 |
expr.save_data | x | 返回 Expr | 可执行 |
expr.save_data_inner | x | 返回 Expr | 接口 |
expr.select | x, y | 返回 Expr | 可执行 |
expr.shift | x | 返回 Expr | 可执行 |
expr.shift_by | x, n | 返回 Expr | 接口 |
expr.shift_intra | x | 返回 Expr | 接口 |
expr.sign | x | 返回 Expr | 可执行 |
expr.skew | x | 返回 Expr | 可执行 |
expr.snapshot_by | x, code | 返回 Expr | 接口 |
expr.sqrt | x | 返回 Expr | 可执行 |
expr.std | x | 返回 Expr | 可执行 |
expr.stream_join | 当前对象 | 返回 Expr | 接口 |
expr.sum | x | 返回 Expr | 可执行 |
expr.temporal_join | 当前对象 | 返回 Expr | 接口 |
expr.to | x | 返回 Expr | 可执行 |
expr.var | x | 返回 Expr | 可执行 |
expr.window_co_group | 当前对象 | 返回 Expr | 接口 |
expr.window_join | 当前对象 | 返回 Expr | 接口 |
expr.with_cols | x, y | 返回 Expr | 可执行 |
expr.with_metadata | x | 返回 Expr | 可执行 |