Я использовал Scala в Spark и попытался сохранить свой файл в файле HDFS, но получил ошибку. Я...

Я использую блокнот Zeppelin для создания скрипта Spark в Scala. Код: def test: DataFrame= { //code...

В версии Spark: 2.4.0 я пытаюсь выполнить приведенный ниже код в указанном DataFrame: unfoldedDF:...

Я изучаю spark и создаю rdd, используя объект SparkContext и используя некоторые локальные файлы s3...

Я могу получить зарегистрированное имя пользователя в порядке со следующим. z.getInterpreterContext

Я столкнулся с ошибкой SLF4J: Class path contains multiple SLF4J bindings в scala.Я знаю, что есть...

Я проверяю искровые десятичные типы для валютных показателей и вижу некоторые странные результаты...

Мы пытаемся использовать Akka Streams с Alpakka Kafka для потребления потока событий в сервисе.Для...

Я пытаюсь создать приложение Spark, работающее в Scala, которое читает файл .csv, расположенный в...

Я пытаюсь работать над scala, чтобы вычислить статистику по моим данным.У меня есть массив кортежей...

Я пытаюсь запустить приложение подсчета слов для потоковой передачи с помощью команды spark-submit

Я пытаюсь использовать это https://stackoverflow.com/a/31641779/1586965 ( Как использовать...

Я пытаюсь создать фрейм данных Spark с данными, извлеченными из SQL Server. val jdbcDF = spark.read...

Я пытаюсь скомпилировать и запустить простой код h2o scala.Но когда я делаю пакет sbt, я получаю...

Мне нужно обработать огромный фрейм данных, загрузить файлы из сервиса по столбцу id фрейма данных

Я изучаю Scala и Spark и хочу получить числа из строки. И для этого я использую регулярное...

У меня есть последовательность строк, которую я хочу использовать в предложении where моих запросов...

Я не могу отправить каждую группу данных за один раз исполнителю. У меня есть данные как в...

Я пытаюсь получить доступ к файлу в alluxio в коде scala в IDE, и я получаю эту ошибку Exception in...

Может ли кто-нибудь объяснить, что означает (p: Char => Boolean)? Как я могу использовать такой...

При попытке прочитать шейп-файл ESRI с помощью приведенного ниже кода я в итоге получаю следующую...

При использовании Geomesa и Scala я пытался закодировать 2 столбца в кадре данных Spark, используя...

Почему для класса дел я могу сделать fieldn: Option[Int] или fieldn: Option[Integer] а для...

Я пытаюсь определить статус завершения на разных уровнях детализации.Например, регион является...

Дано: val df = Seq((1L, "04-04-2015")).toDF("id", "date") val df2 =...