chronaxis.core.sample_reduction_reference
逐个处理真实更新,计算样本最小值、最大值和算术平均值,供NumPy实现对照。整数极值保留整数精度;平均值按输入顺序累加。保持出来的值和窗口边界不算新样本。
这是模块参考。日常调用先查公开API索引;下划线对象和嵌套函数供维护者查阅。签名来自固定源码,公开类构造签名经实际Python接口核对。
相关类型
D、ExactQuantileBuffer、Interval、QualityFlag(源码别名Q)、ReferenceIntegralSum、ReferenceMoments、SampleCalculationFacts、SampleReductionResult、ScalarValue
对象导航
| 对象 | 用途 |
|---|---|
ReferenceSampleReduction |
累计当前范围的真实样本;分位数仅在请求时按共享预算保留原dtype样本。 |
ReferenceSampleReduction.__init__ |
核对原配置并建立本参考后端有限状态。 |
ReferenceSampleReduction.selected_duration_ns |
读取累计TRUE值有效时长。 |
ReferenceSampleReduction.value_valid_duration_ns |
读取累计值有效时长。 |
ReferenceSampleReduction.valid_sample_count |
读取有效真实样本数。 |
ReferenceSampleReduction.push |
处理下一块数据,更新数值和条件的覆盖统计,并累计真实更新的样本;保持出来的时间段不增加样本数。 |
ReferenceSampleReduction.finish |
完成原单位总和、除真实样本数,再仅一次转换输出单位。 |
ReferenceSampleReduction.close |
退回按需分位数存储;无动态存储的样本归约无需释放费用。 |
导入与重导出来源(展开)
from .moments import SAMPLE_MOMENTS
from .quantiles import SAMPLE_QUANTILES, ExactQuantileBuffer
from .moments_reference import ReferenceMoments
from math import isfinite
from .calculation_output_reference import convert_result_reference
from .integral_sum_reference import ReferenceIntegralSum
from .calculations import merge_ranges
from .models import Interval
from .numeric import ScalarValue, to_float_reference
from .sample_reduction import SampleCalculationFacts, SampleReductionResult, require_sample_config, require_sample_series
from .types import QualityFlag as Q, SignalDType as DReferenceSampleReduction
累计当前范围的真实样本;分位数仅在请求时按共享预算保留原dtype样本。
ReferenceSampleReduction(spec, input_unit, dtype, *, partial_limit=4096, quantile_budget=None)源码:src/chronaxis/core/sample_reduction_reference.py:24(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.__init__
核对原配置并建立本参考后端有限状态。
ReferenceSampleReduction.__init__(spec, input_unit, dtype, *, partial_limit=4096, quantile_budget=None)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
spec |
CalculationDefinition | 是 | 无 | 位置或关键字。本次指标的设置,包括统计时间范围、计算种类、输出单位及数据不全时的处理方式。该对象由调用方先构造;本函数不会重新读取JSON配置。 |
input_unit |
str | 是 | 无 | 位置或关键字。输入信号当前使用的单位,例如功率填"W"。函数据此检查输出单位的换算关系,不会仅凭这个字符串修改样本值。 |
dtype |
SignalDType | 是 | 无 | 位置或关键字。输入值的逻辑类型,传SignalDType成员;整数极值计算保持整数精度,均值按本函数说明转换为浮点。 |
partial_limit |
int | 否 | 4096 | 仅关键字。大于0的整数,限制浮点累加时保留的误差补偿项数量。默认4096;它不是样本数上限,也不是允许出现多少次错误。超过容量会报错。 |
quantile_budget |
ResourceBudget | None | 否 | None | 仅关键字。可选的共享排序预算,仅配置精确分位数或中位数时用于保存所选样本。 |
返回说明
返回None,不返回额外的计算值。
异常说明
配置或分配错误传播。
源码:src/chronaxis/core/sample_reduction_reference.py:27(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.selected_duration_ns
读取累计TRUE值有效时长。
ReferenceSampleReduction.selected_duration_ns装饰器:property。
读取属性,不使用调用括号。
参数说明
无。
返回说明
原生int纳秒。
异常说明
无。
源码:src/chronaxis/core/sample_reduction_reference.py:47(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.value_valid_duration_ns
读取累计值有效时长。
ReferenceSampleReduction.value_valid_duration_ns装饰器:property。
读取属性,不使用调用括号。
参数说明
无。
返回说明
原生int纳秒。
异常说明
无。
源码:src/chronaxis/core/sample_reduction_reference.py:52(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.valid_sample_count
读取有效真实样本数。
ReferenceSampleReduction.valid_sample_count装饰器:property。
读取属性,不使用调用括号。
参数说明
无。
返回说明
原生int。
异常说明
无。
源码:src/chronaxis/core/sample_reduction_reference.py:57(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.push
处理下一块数据,更新数值和条件的覆盖统计,并累计真实更新的样本;保持出来的时间段不增加样本数。
ReferenceSampleReduction.push(series, *, sample_consumer=None)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
series |
CalculationSeries | 是 | 无 | 位置或关键字。本次要处理的一块时间和值,单位、dtype和绑定必须与构造时一致。带条件的计算还需要与值对齐的BOOL条件;push处理当前块后保留累计结果,下一块可继续调用。 |
sample_consumer |
Callable[[tuple[ScalarValue, ...]], None] | None | 否 | None | 仅关键字。可选的宿主消费入口,只收到本块实际更新且通过选择和质量检查的数值。 |
返回说明
SampleCalculationFacts;mean精度失败进入输入覆盖,求和故障不改覆盖。
异常说明
结构、身份、容量、分配或取消传播;外层异常后不能接着使用前缀状态。
本函数直接报告的具体错误:
ValueError:样本归约不能跨绑定身份累计。
源码:src/chronaxis/core/sample_reduction_reference.py:61(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.finish
完成原单位总和、除真实样本数,再仅一次转换输出单位。
ReferenceSampleReduction.finish()参数:无显式参数。
参数说明
无。
返回说明
SampleReductionResult快照,不清空状态或分类覆盖政策。
异常说明
配置/分配错误传播;原序和、除法、精度或换算故障返回None及质量。
源码:src/chronaxis/core/sample_reduction_reference.py:138(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。
ReferenceSampleReduction.close
退回按需分位数存储;无动态存储的样本归约无需释放费用。
ReferenceSampleReduction.close()参数:无显式参数。
参数说明
无。
返回说明
None。
异常说明
预算释放失败时保留可重试的子缓冲。
源码:src/chronaxis/core/sample_reduction_reference.py:178(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。