scalding

2зной

2ответ

Как ошпаривание передаёт пользовательские функции удаленным узлам MapReduce

При работе с Scalding у вас есть возможность предоставить функцию. Мне было интересно, как ошпаривание передает эти функции удаленной карте/сокращению задач? Это что-то использует в scala или что-то о

java scala scalding 2013-03-07

---

2зной

1ответ

обжиг сравнения последовательных записей

Кто-нибудь знает, как сравнивать последовательные записи в scalding при создании схемы. Я смотрю на уроке 6, и предположим, что я хочу, чтобы напечатать возраст человека, если данные в звукозаписывающ

scala enums scalding 2013-06-16

---

0зной

1ответ

Почему экранированные пары стираются?

Я пытаюсь понять пример here, который вычисляет сходство Jaccard между парами векторов в матрице. val aBinary = adjacencyMatrix.binarizeAs[Double] // intersectMat holds the size of the intersection

scala scalding 2013-07-02

---

1зной

2ответ

Как оценивать несколько столбцов сразу в Scalding?

В качестве последнего шага по некоторым вычислениям с помощью Scalding я хочу вычислить несколько средних столбцов в трубе. Но следующий код не работает myPipe.groupAll { _average('col1,'col2, 'col3)

hadoop cascading scalding 2013-03-26

---