Я бегу Спарк на пряжи Hadoop. Как работает это преобразование? Имеется ли метод collect () перед преобразованием?

Также мне нужно установить Python и R на каждом подчиненном узле для преобразования для работы? Я изо всех сил пытаюсь найти документацию по этому вопросу.