java - 持久聚合后 Storm Trident newValueStream 是否维护来自 groupBy 的分区

Question

我目前正在尝试扩展一个三叉戟拓扑，该拓扑在 groupBy 和 persistentAggregate 之后进行一些后处理，在聚合步骤之后使用 newValueStream 流式传输值。我想知道元组是否像在 groupBy 步骤中那样保持分区，或者它们是否以其他方式重新分配。

相关代码：

.groupBy(new Fields("key"))
.name("GroupBy")
.persistentAggregate(new MemoryMapState.Factory(), new Fields("foo", "bar"), new Aggregator(), new Fields("foobar"))
.newValuesStream()
.name("NewValueStream")