spark-graphx

3зной

1ответ

reduceByKey обработки каждого выходного flatMap без агрегирования значения по ключу в Graphx

У меня есть проблемы запуска Graphx val adjGraph= adjGraph_CC.vertices .flatMap { case (id, (compID, adjSet)) => (mapMsgGen(id, compID, adjSet)) } // mapMsgGen will generate a list of msgs

scala mapreduce apache-spark spark-graphx 2014-12-24

---

0зной

1ответ

Spark - Graphx: mapReduceTriplets против aggregateMessages

Я бегу на уроке http://ampcamp.berkeley.edu/big-data-mini-course/graph-analytics-with-graphx.html И в какой-то момент мы используем операции mapReduceTriplets. Это возвращает ожидаемый результат // Fi

mapreduce apache-spark spark-graphx 2014-12-30

---

0зной

1ответ

Что такое индексирование CSR в качестве метода оптимизации соединения?

Искра Graphx бумага упоминает CSR индексацию в следующем контексте: Graphx переделывает систему оптимизации, разработанной в контексте систем обработки графа , как присоединиться к оптимизации (наприм

apache-spark join query-optimization spark-graphx 2015-01-13

---