hck1могу. один файл
1.
2.
3.
4.
5.
field1;obj1;{val1,val2}
field2;obj1;{val3,val4,val5}
field1;obj2;{val11,val22}
field3;obj1;{val6,val7}
field2;obj1;{val33,val44,val55}
теперь мапер может отфильтровать ненужные obj# и field#, а вот кто (маппер или редюсер) из оставшегося строит объекты я уже и запутался.
список обычных денормализованных записей. map преобразует каждую запись к агрегату - первый шаг.
дальше используется свойство ассоциативности и комутативности агрегата
A+B = B + A
(A+B)+C = A+(B+C)
(вместо сложения может быть любая операция удовлетворяющая этим свойствам)
эти свойства и позволяют разделить работу на ноды
PS: по фильтру, так как агрегат комплексный (по сути список самих исходных записей) - это не очень хорошее решение. Хорошим агрегатом может быть, например, количество записей, удовлетворяющее фильтру
