rdd

1зной

3ответ

Как удалить строки RDD, чей ключ не находится в другом RDD?

Предположим, у меня есть PairRDD, студенты (id, имя). Я хотел бы сохранить только строки, где id находится в другом RDD, activeStudents (id). Решение, которое у меня есть, - это создать PairDD из acti

1зной

2ответ

Элементы сортировки элементов python, основанные на значении

Я новичок в искры python, и мне нужна ваша помощь, заранее за это спасибо! Так вот мы идем, у меня есть этот кусок сценария: from datetime import datetime from pyspark import SparkContext def getNo

2зной

1ответ

Работа столбца на Spark RDD

У меня есть RDD с несколькими столбцами (например, сотнями), и большая часть моей операции находится на столбцах, например. Мне нужно создать много промежуточных переменных из разных столбцов. Каков н

0зной

1ответ

В Spark RDD Println Ошибка, как я могу представить данные, такие как [Ljava.lang.String; @ 8e6606

У меня есть одна проблема с Apache Spark, использующая Scala. Я пытаюсь создать приложение Spark, которое выводит RDD из пользовательского ввода. Входные данные, как это: List("aaaa","aaaa","dfddf","a

0зной

1ответ

Попытка получить искрообразование для чтения потока данных с сайта, что такое сокет?

Я пытаюсь получить эти данные http://stream.meetup.com/2/rsvps в искровой поток Они являются объектами JSON, я знаю, что линии будут строки, я просто хочу, чтобы работать, прежде чем я попробовать JSO