Вопросы с тегом рдд

0 голосов

1 ответ

потеря данных при чтении файла огромного размера в spark scala

Sayantan / 16 марта 2020

0 голосов

0 ответов

Преобразуйте RDD (PySpark / Python), чтобы получить обратно отсортированный POS с наибольшим количеством слов на слова с тегами «Часть речи» (POS)

New_to_Python / 13 марта 2020

2 голосов

1 ответ

Что произойдет, если я использую lowerByKey или groupByKey один большой набор данных, имеющий только два ключа

Pirate / 12 марта 2020

1 голос

1 ответ

Как выполнить операцию на случайных парах элементов СДР?

SrdjanBL2902 / 12 марта 2020

0 голосов

2 ответов

Как вы получаете партии строк из Spark, используя pyspark

csteel / 12 марта 2020

2 голосов

2 ответов

Как рассчитать количество слов на строку в pyspark

Diwakar Kumar / 11 марта 2020

0 голосов

0 ответов

Apache Spark: запись на несколько листов в Excel

Arjun / 09 марта 2020

0 голосов

0 ответов

Какую структуру лучше выбрать для обновления свойства узлов в Spark GraphX?

Miguel A. Friginal / 05 марта 2020

1 голос

0 ответов

Почему JavaRDD count () возвращает другой результат?

Peter / 03 марта 2020

0 голосов

0 ответов

Ошибка в Spark: преобразование RDD в DSTREAM с использованием другого rdd

karim alami / 03 марта 2020

1 голос

1 ответ

Как упомянуть отдельные имена листов при записи нескольких org. apache .spark. sql .Dataset в файл .xls с использованием crealytics / spark-excel в java?

Niranjan Balasubramani / 03 марта 2020

0 голосов

0 ответов

как читать ShuffledRDD с контрольной точки в спарк

user2999357 / 28 февраля 2020

0 голосов

1 ответ

Как прочитать текстовый файл, разделенный несколькими символами в PySpark?

Codefactory / 26 февраля 2020

2 голосов

1 ответ

Преобразование MapPartitionsRDD в DataFrame и группирование данных по 2 ключам

meisan / 26 февраля 2020

1 голос

0 ответов

Создать основанный на столбцах фрейм данных из двух RDD в pyspark

Ghifari Rahadian / 25 февраля 2020

0 голосов

1 ответ

проблема pyspark с круглой функцией

bsadhukhan / 24 февраля 2020

1 голос

0 ответов

Исключение Serializable Spark Task

Susmit Sarkar / 22 февраля 2020

0 голосов

1 ответ

Какой самый эффективный способ вызвать немедленное кэширование в Spark?

KyleL / 20 февраля 2020

0 голосов

1 ответ

Как сохранить каждую строку DataFrame в виде файла HDFS с помощью pyspark

Kuwali / 19 февраля 2020

0 голосов

1 ответ

Dtream to Rdd в Искорно-Страминге

Daniel Carretero / 19 февраля 2020

0 голосов

1 ответ

Конвертировать JavaRDD в JavaRDD <SomeClass>

IncompleteCoder / 17 февраля 2020

0 голосов

0 ответов

Если я кеширую Spark Dataframe, а затем перезаписываю ссылку, будет ли сохраняться исходный фрейм данных?

Zhengyuan Ma / 17 февраля 2020

0 голосов

1 ответ

Дважды сопоставьте PySpark RDD для группировки по разным ключам

cybertextron / 16 февраля 2020

2 голосов

0 ответов

Почему эта Apache линия Spark вызывает исключение OutOfMemoryException (превышен предел издержек G C)?

Joe Strout / 16 февраля 2020

0 голосов

0 ответов

flatMapToPair в Scala на JavaRDD

CSUNNY / 15 февраля 2020