小编gir*_*der的帖子

我正在使用Storm(java)和Cassandra.

我的一个Bolts将数据插入到Cassandra中.有没有办法在这个螺栓的实例化之间保持与Cassandra的连接？

我的应用程序的写入速度很快.螺栓需要每秒运行几次,并且每次连接到Cassandra的事实都会阻碍性能.

如果我可以保持打开的静态连接,它会运行得更快,但我不确定在风暴中实现这一点.

澄清问题:

风暴拓扑中静态连接的范围是什么？

与其他消息系统不同的是,工作中的"工作"在循环或回调中进行,可以在此循环之外使用变量(可能是静态连接),风暴螺栓似乎每次被调用时都会被实例化,而不能将参数传递给它们,那么如何使用与cassandra相同的连接？

我有一个疑问：

    select sum(
        sum((Impressions / Count) * Volume) / sum(Volume)
    ) as frequency 
    from datatable;

但是我无法在 postgres 中执行它，因为它使用嵌套聚合。有没有另一种方法可以在不使用嵌套聚合的情况下编写它？