Сжатие в системе с распределенной памятью

Реализовать деление массива на фрагменты ~~равного размера (кроме последнего)~~,
хранение в файле сжатых фрагментов,
чтение и рассылка узлам необходимых им фрагментов (могут дублироваться),
распаковку и отбрасывание ненужных строк узлами параллельно,
параллельную запаковку на фрагменты ~~равного размера (возможно, понадобится пересылка строк между узлами)~~,
пересылку запакованных фрагментов управляющему узлу,
запись запакованных фрагментов в файл.