У меня есть преобразователь, вывод которого сопоставлен с несколькими различными экземплярами редуктора с использованием моего собственного Partitioner.Мой разделитель следит за тем, чтобы данные всегда отправлялись в данный экземпляр редуктора.Что меня интересует, так это то, что если по каким-то причинам входные данные искажены, и я получаю, скажем, миллион записей (точнее, #records не может поместиться в память) для определенного ключа, есть ли какой-нибудь возможный способ, которым редуктор будетвсе еще работает нормально?Я имею в виду, является ли итерация итерируемой, которая передается редуктору ленивому загрузчику?