将值转换为 date，用于 pa.date32() 列。 支持格式： - 'YYYY-MM-DD' (BaoStock, Sina) - 'YYYY-MM-DD 00:00:00' (EastMoney) - 'YYYYMMDD' (THS) - date/

将值转换为 float，用于 pa.float64() 列。 None → 返回 None（缺失值） 转换失败时抛出 SchemaTypeError。

将值转换为 int，用于 pa.int64() 列。 None → 返回 None（缺失值） 转换失败时抛出 SchemaTypeError。

将时间值转为 datetime。 支持格式： - Unix 秒/毫秒时间戳（THS）: '1776130842' - 'YYYY-MM-DD HH:MM:SS'（JiuYan）: '2026-05-29 12:00:15' - ISO datetime 字符串: '

在执行 ClickHouse 操作前校验请求。

将值转换为 string，用于 pa.string() 列。 None → 返回 None（缺失值） 永不抛出异常，任何值都能转为字符串。

Return true when this mode writes production rows.

为单只证券的有序时间序列计算 KDJ 输出。 无效或不完整的输入行会输出 `None` 指标字段，并且不会推进递归 K/D 状态。 日级增量运行应传入上一轮 `previous_state`；当其为 `None` 时， `initial_k=50` 和 `initial_d=50` 只用于第一次有

Calculate MACD outputs for one ordered security series. # Errors Returns an error when parameters are invalid, input prices are invalid, or input `t

Return the physical ClickHouse type implied by contract nullable facts.

判断参数是否为首个生产标准 KDJ 参数集。

构造将单个年份分区从 staging 表替换到目标表的 SQL。

从行数据和 schema 构建 pa.Table，自动应用类型转换。 None 值直接追加，不经过转换函数（转换函数会抛出异常）。