Передача размера фрагмента в ItemReader, агрегированный в другом пользовательском ItemReader

Question

Я создал пользовательскую программу чтения предметов, как и

public class AggregateItemReader<T> implements ItemReader<List<T>> {

   private static final Log LOG = LogFactory.getLog(AggregateItemReader.class);

   private ItemReader<AggregateItem<T>> itemReader;

}

Когда я вызываю ридер с шага, я передаю размер куска, но этот размер куска не передается ItemReader в AggregateItemReader, и он считывает все записи, упомянутые в запросе. Не могли бы вы дать мне знать, как передать размер чанка в ItemReader внутри другого Reader

Answer 1

Читатель не знает о размере чанка.Это шаг, который вызывает читателя и решает, когда блок завершен.Таким образом, в вашем случае ни AggregateItemReader, ни делегат не могут получить эту информацию, вы должны передать эту информацию во время конфигурации обоим этим компонентам.