0

我能够使用 TridentState 提供的 partitionpersist api 批量处理事件流。但是现在，我想发出这个螺栓的处理值，并将它们作为另一批事件收集到下一个螺栓中。

4

1 回答 1

0

state.newValuesStream()您的 TridentState 上的方法正是这样做的——它从您的 TridentState 返回一个新更新的值流。

于 2014-05-30T10:27:24.010 回答