2013-02-11 61 views
0

我想知道(并且几乎变得绝望)是否有任何针对有序的对象系列上的流/迭代器的DSL?有什么DSL流/迭代器?

来源是id,time,key,value实例的有序流,而要求是加入并分析这些流。这必须通过收集密钥组合并将度量指标应用于某些(可定义的)时间约束内的值(在同一秒内计算一天内的不同密钥或求和值..)来完成。有一些DSL在时间序列(ESP)上工作,但主要使用相对简单的时间窗口,并且他们似乎无法通过id,时间等来处理命令/连接(并且因此通过id计算组合)。

我需要做的就是类似“计算A的组合和(B或C),计算同一秒内不同d,用相同的ID和E”

结果应包含所有可用组合A,(B或C),其中对于关键D的不同值的计数与A相同,(B或C)对于每个不同的id以及对于每个id的关键字E的值的总和(B或C)的所有值的总和。

不是一个简单的问题。我只是寻找可能有用的,已经想到了DSL这样的问题。我不认为SQL会使它

非常感谢!

+2

一旦Slick有类型提供者,你可能希望以这种方式实现它。如果您希望自由创建任意且优化的查询语法,则内部DSL可能会过于严格。 – 2013-02-11 23:37:12

+0

您是否在寻找用于复杂事件处理(CEP)的DSL?你希望它是基于持久层(基于数据库还是基于内存)还是基于集合的API? – 2013-02-12 10:37:25

回答

0

我认为你不能找到这样的方法,因为streamsiterators不打算包含有序的数据(但他们可以)。因此,如果你不能依赖内部的排序数据,那么在这种方法中就不需要了,因为你需要从流/迭代器中读取所有数据,因此它们将失去作为数据结构的主要目的。那么为什么不使用列表?