BaseStatefulBolt（风暴核心）与 StateFactory（风暴三叉戟）

Posted 2023-03-31

【中文标题】BaseStatefulBolt（风暴核心）与 StateFactory（风暴三叉戟）

【英文标题】：BaseStatefulBolt (Storm Core) vs StateFactory (Storm Trident)

【发布时间】：2017-03-28 12:16:37

【问题描述】：

我对使用风暴感到困惑。我将使用其流数据来测量数据源的状态。状态将通过组合一些字段来计算，这些字段可以实现不同的时间间隔。这就是为什么我需要保存字段来衡量数据源的状态。

我可以使用 BaseStatefulBolt 吗？或者这个场景的唯一解决方案是三叉戟？

btw 他们有什么区别。因为 trident 里面也有 statefactory。

谢谢。

【参考方案1】：

我认为区别在于 trident 比 BaseStatefulBol 级别更高，它有一些计数选项，如 group by、persistentAggregate、aggregate。

我使用 trident 来计算每个用户的总观看次数。如果我们只关心当前的总计数，我认为我们可以通过 MemoryMapState.Factory() 和类实现动作来使用三叉戟进行计数或求和。

在您的情况下，您需要管理一些当前字段的状态，我认为实现 BaseStatefulBolt 是一个不错的选择，它具有用于保存当前状态的 KeyValueState。