rdd

1зной

2ответ

Как выполнить операцию соединения на двух схемах RDD?

У меня есть два SchemaRDD, и я хочу выполнить операцию соединения на них (то же, что и SQL-соединение). , пожалуйста, помогите мне.

apache-spark rdd 2014-08-22

---

2зной

1ответ

Spark scala RDD traversing

Как я могу пройти через RDD, используя Spark scala. Я хочу распечатать каждое значение, присутствующее в Seq, с помощью связанного ключа res1: org.apache.spark.rdd.RDD[(java.lang.String, Seq[java.lang

scala map apache-spark rdd 2014-09-02

---

1зной

1ответ

Использование foreach с Spark RDD в python

Я пытаюсь выполнить очень большое RDD, выполняющееся на кластере, и записать его в .csv. Это настолько велико, что .collect() ломается, поэтому вместо этого я хотел бы сохранить RDD на куски на каждом

python foreach apache-spark rdd 2014-09-11

---

42зной

2ответ

Как DAG работает под обложками в RDD?

Spark research paper предписывает новую распределенную модель программирования над классическим Hadoop MapReduce, требуя упрощения и увеличения производительности во многих случаях специально для маши

apache-spark rdd directed-acyclic-graphs 2014-09-14

---

0зной

1ответ

Как получить доступ к значениям за пределами цикла Spark GraphX ​​.map?

Совершенно новый для Apache Spark, и я немного смущен, как сделать обновления для значения, которое находится за пределами итерации .mapTriplets в GraphX. Смотрите ниже: def mapTripletsMethod(edgeWeig

multithreading scala apache-spark colt rdd 2014-09-16

---