Допустим, у меня есть искровой фрейм данных, который включает в себя категориальные столбцы (школа,...
У меня есть файл Geojson, и я хочу извлечь схему (structtype), соответствующую с помощью spark....
Я пытаюсь найти ключ в некотором подпространстве в FoundationDB с помощью getKey и KeySelector. В...
Я использую fs2.Stream, и у меня есть вопрос о параллельной обработке.У меня есть fs2.Stream[F, O]...
У меня есть пример файла, который я пытаюсь выяснить для данного поля общее число другого поля и...
Я выполняю свою искровую работу в кластере Emr, и я использую Hive Tables в качестве источника...
Попытка загрузить CSV-файл без вывода схемы. Обычно мы создаем схему как StructType в коде искры....
получая это предупреждение ниже при попытке создать временную таблицу, помогите решить это...
У меня есть требование получить глобальную HashMap от RDD [HashMap]. Например, СДР - это СДР...
Код написан на scala, но исключение взято из java.lang.Я пытаюсь подключить мое основное приложение...
Можем ли мы использовать Slick для подключения к базе данных в потоке данных Google?Или...
Я пытаюсь запустить код по этой ссылке: https://hbase.apache.org/book.html#_save_the_dataframe Но я...
Мне нужно отказаться от полного пакета.Я могу сделать это, написав @Deprecated аннотацию в каждом...
Я сделал простое приложение для подключения к MySQL, используя только один файл scala и scala-2.11
У меня проблема с модулем Spark GraphX. У меня кластер из 5 узлов, с 23,5 ГБ памяти и 24 ядрами на...
Может кто-нибудь посоветовать мне, как анализировать данные формата EDIFACT с помощью Apache spark?...
Я пытаюсь вычислить среднеквадратическую ошибку (RMSE) вручную на Spark (Scala 2.11) Как показано...
Я новичок в использовании spark и пытаюсь вычислить огромные данные и отправить их в целевую базу...
Мне интересно, результат кода object localTest { def hello = { var t = 3 () => { t = t + 3...
Я пытаюсь подобрать кривую с SimpleCurveFitter из commons.math3.fitting в Scala, но я улавливаю...
Я новый ученик Scala. Теперь дан DataFrame с именем df следующим образом:...
SPARK-26039 При загрузке пустой папки orc. В любом случае, чтобы обойти это. val df = spark.read
Я пытаюсь типизировать столбцы во фрейме данных df_trial, в котором все столбцы представлены в виде...
Не используя бесформенную библиотеку, можем ли мы динамически создать класс case с использованием...
У меня вопрос об использовании аккумуляторов в СДР и о том, как их надежно использовать. Итак,...