聚合处理器或聚合 reader
Aggregating processor or aggregating reader
我有一个要求,就像,我从数据库中读取项目,如果可能的话,以项目代表后面的分页方式"batch size",我做一些处理步骤,比如过滤等。然后我想积累物品以将其发送到休息服务,在那里我可以将它分批发送到,例如n 一次而不是一个接一个。
我正在做的是在步级上并行化它,但我不确定如何让批处理工作,我是否需要实现 reader 那个 returns 列表和接收列表的处理器?如果是这样,我读到您将没有正确的处理项目数的帐户。
我正在尝试找到一种方法以最合适的 spring 批处理方式而不是破解修复,我还假设我需要在 reader 中保持状态并且想知道如果有更好的办法不要。
你不能有聚合处理器之类的东西。读取的每个项目都作为单个项目处理。
但是,您可以实施 Reader 对项目进行分组并将它们作为一个整体转发。要了解如何做到这一点,请查看我对这个问题的回答 Spring Batch Processor or Dean Clark's answer here Spring Batch-How to process multiple records at the same time in the processor?。
两者都使用 SpringBatch 的 SingleItemPeekableItemReader。
我有一个要求,就像,我从数据库中读取项目,如果可能的话,以项目代表后面的分页方式"batch size",我做一些处理步骤,比如过滤等。然后我想积累物品以将其发送到休息服务,在那里我可以将它分批发送到,例如n 一次而不是一个接一个。
我正在做的是在步级上并行化它,但我不确定如何让批处理工作,我是否需要实现 reader 那个 returns 列表和接收列表的处理器?如果是这样,我读到您将没有正确的处理项目数的帐户。
我正在尝试找到一种方法以最合适的 spring 批处理方式而不是破解修复,我还假设我需要在 reader 中保持状态并且想知道如果有更好的办法不要。
你不能有聚合处理器之类的东西。读取的每个项目都作为单个项目处理。
但是,您可以实施 Reader 对项目进行分组并将它们作为一个整体转发。要了解如何做到这一点,请查看我对这个问题的回答 Spring Batch Processor or Dean Clark's answer here Spring Batch-How to process multiple records at the same time in the processor?。
两者都使用 SpringBatch 的 SingleItemPeekableItemReader。