我能够使用tridentstate提供的partitionpersistapi成批处理事件流。但是现在，我想发出这个bolt的已处理值，并将它们作为下一个bolt中的另一批事件来收集。
8ehkhllq1#
这个 state.newValuesStream() 方法就可以做到这一点——它从tridentstate返回一个新更新的值流。
state.newValuesStream()
1条答案
按热度按时间8ehkhllq1#
这个
state.newValuesStream()方法就可以做到这一点——它从tridentstate返回一个新更新的值流。