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

Question

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

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

他们有什么区别。因为三叉戟内部也有一个statefactory。

谢谢你。

Answer 1

我认为不同之处在于 trident 比 BaseStatefulBol 级别更高，它有一些计数选项，例如 group by,persistentAggregate,aggregate 。

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

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