#110 tail-sampling 时间轮内存优化：压缩入轮 + span 谓词标记 + 决策免解压 + 大包分级落盘

[songlonqi-java]

背景

tail-sampling 时间轮按"全量展开数据 × TTL"常驻内存。按客户实测（压缩 12TB/天、展开 170TB/天）：TTL=30s 驻留 ~35GB，TTL=60s ~71GB，单机内存的主要压力源。

改动（aggregate 包）

1. payload 压缩入轮

• DataPacket 新增 payload_compression（0=raw / 1=zstd），PickTrace 组包后压缩，小包无收益自动回退
• WalkRawPBPoints / 合并路径按标记解压；时间轮驻留从展开态降为压缩态（~10-17x）

2. span 谓词标记（跨 Datakit OR 合并）

• DataPacket 新增谓词字段：pred_error / pred_http_error / pred_biz_error / pred_trace_keep / max_span_duration_us / root_duration_us / max_nonroot_duration_us
• PickTrace 组包时提取（缺失字段不命中，与 filter 语义严格一致，逐 case 等价测试）；Ingest 合并路径 OR 聚合（跨 datakit 任一命中即命中）
• 导出 ComputeSpanPredicates：dataway 对旧版 datakit 数据补算，解除版本绑定

3. 决策免解压

• condition 静态编译为谓词判定（filter AST 白名单：error/4xx5xx/body_code/trace_keep/root/非根/任意 duration 阈值），未覆盖或谓词全零回退解压 walk（行为不变）
• 损坏 payload 首点预检保持原语义（空 payload 不匹配）

4. 大包分级落盘

• PayloadSpiller 接口 + FilePayloadSpiller（打开时清空崩溃残留、key 字符集防路径穿越）
• GlobalSampler.SetPayloadSpiller：超阈值 payload 落盘，时间轮只存元数据；决策惰性读回（谓词可覆盖时零读盘），决策后释放

测试

• 新增 4 组测试文件（zstd / predicates / pipeline_predicates / spill），含与 filter 求值逐 case 等价性、跨 datakit 合并、快速 vs walk 对照、落盘读回计数
• go test ./aggregate/：ok
• golangci-lint run ./aggregate/...：新增代码 0 issues

风险点

• proto 新增字段向后兼容（旧读取方按 0 处理）
• 谓词为"已见 span"摘要语义；谓词全零（旧数据）由 dataway 补算，补算失败回退 walk
• 发布顺序：cliutils → dataway → datakit（dataway 需能解压后再升级 datakit 启用压缩）

[CLAassistant]

All committers have signed the CLA.