2
При работе с Scalding у вас есть возможность предоставить функцию. Мне было интересно, как ошпаривание передает эти функции удаленной карте/сокращению задач? Это что-то использует в scala или что-то общее, что можно сделать с анонимными объектами?Как ошпаривание передаёт пользовательские функции удаленным узлам MapReduce
Как каскадные пропускают анонимные объекты для отображения/уменьшения задач? Я знаю, как это сделать, если задание задано классом и создать его самостоятельно, но с анонимным объектом это не так ясно. – ekaqu