我想批量处理我想使用 Trident API 的元组。但是，这里没有我批量执行的操作。每个元组都是单独处理的。我在这里需要的只是一次性语义，这样每个元组只处理一次，这是使用 Trident 的唯一原因。
我想存储处理哪个元组的信息，以便在重播批处理时，已经处理的元组不会被执行。
拓扑包含一个persistentAggregate()方法，但它需要一些聚合操作，但我没有对一组元组执行任何聚合操作，因为每个元组都是单独处理的。
在这里，元组所经历的功能太小而无法执行。因此，我希望批量处理它们以节省计算资源和时间。
现在，如何编写一个将元组作为批处理消耗但仍然不执行任何批处理操作（如字数统计）的拓扑？