Я пытаюсь разбить плоский входной файл, содержащий ;
разделенных элементов.первый элемент в строке указывает категорию, и я хотел бы разделить на эту категорию, чтобы для каждой категории был создан раздел, который будет обрабатываться выделенным потоком.Но я озадачен тем, как я могу реализовать эту логику разделения в пользовательском Partitioner
.Кажется, что разделение происходит перед этапом, ориентированным на чанк, то есть перед чтением и записью, поэтому мне кажется, что мне нужно построчно прочитать файл в пользовательском разделителе, получить строку категории из строки, собрать строки с равными категориями и создатьExecutionContext
для каждой из этих коллекций?
Я смотрю в правильном направлении?Может ли кто-нибудь со стажем привести небольшой пример использования файла (может быть, псевдокод)?