我想知道(并且几乎变得绝望)是否有针对有序系列对象的流/迭代器制定的 DSL?
源是 id、time、key、value 实例的有序流,要求是加入和分析这些流。这必须通过收集键组合并将指标应用于某些(可定义的)时间限制内的值(在一天内、同一秒内计算不同的键或总和值)来完成。有一些适用于时间序列 (ESP) 的 DSL,但主要使用相对简单的时间窗口,它们似乎无法通过 id、时间等处理订单/连接(因此通过 id 计算组合)。
我要做的是“计算A和(B或C)的组合,在同一秒内计算不同的D,将E与相同的ID相加”
结果应包含 A、(B 或 C)的所有可用组合以及键 D 的不同值的计数,这些值与每个不同 id 的 A、(B 或 C)在同一秒内以及键的值的总和每个 id 的 E(这是 id 具有 A、(B 或 C)的所有 E 值的总和。
这不是一个简单的问题。我只是在寻找可能对此类问题有用的、已经考虑过的 DSL。我不认为 SQL 会成功。
非常感谢!