Должно ли количество выходных записей map () / mapPartition () совпадать с количеством входных записей? - PullRequest
0 голосов
/ 29 ноября 2018

Если у меня есть набор данных из 100 записей, разбитых на 10 разделов, и если я запускаю над ним функцию mapPartition, должен ли размер выходного набора данных быть равен 100?Или я могу иметь более 100 записей?(например, плоская карта) Пример кода:

Dataset<Ledger> ledger = balance.mapPartitions(new customTransformationFunction(config)),
                Encoders.bean(Ledger.class));

Может ли размер набора данных главной книги быть больше 100?

...