estenda MongoItemReader e forneça sua própria implementação para o método doPageRead(). Assim você terá total suporte à paginação e essa leitura dos documentos será parte de uma etapa.
public class CustomMongoItemReader<T, O> extends MongoItemReader<T> {
private MongoTemplate template;
private Class<? extends T> inputType;
private Class<O> outputType
private MatchOperation match;
private ProjectionOperation projection;
private String collection;
@Override
protected Iterator<T> doPageRead() {
Pageable page = PageRequest.of(page, pageSize) //page and page size are coming from the class that MongoItemReader extends
Aggregation agg = newAggregation(match, projection, skip(page.getPageNumber() * page.getPageSize()), limit(page.getPageSize()));
return (Iterator<T>) template.aggregate(agg, collection, outputType).iterator();
}
}
E outros getters e setters e outros métodos. Basta dar uma olhada no código-fonte do MongoItemReader aqui .Eu também removi o suporte Query dele. Você pode ter isso também no mesmo método, basta copiar e colar do MongoItemReader. O mesmo com Sort.
E na classe onde você tem um leitor, você faria algo como:
public MongoItemReader<T> reader() {
CustomMongoItemReader reader = new CustomMongoItemReader();
reader.setTemplate(mongoTemplate);
reader.setName("abc");
reader.setTargetType(input.class);
reader.setOutputType(output.class);
reader.setCollection(myMongoCollection);
reader.setMatch(Aggregation.match(new Criteria()....)));
reader.setProjection(Aggregation.project("..","..");
return reader;
}
