Я пытаюсь транслировать живые твиты с помощью Spark / Scala.У меня возникли некоторые трудности. Я...
У меня есть две таблицы данных spark sql, у которых нет ни одного уникального столбца.Первый фрейм...
Я использую пакет IBMSparkGPU / GPUenabler.Я использую сборку sbt, чтобы упаковать всю зависимость...
У меня есть пара ключ-значение, где значением является нетипизированный массив Javascript:...
В Scala Anorm с MySQL кажется, что соединение более одного раза в запросе несколько раз и работа с...
Я перехожу с Spark 1.6 на 2.3. Мне нужно зарегистрировать пользовательские классы в Kryo.Итак, что...
Я пытаюсь запросить SQL-сервер, используя Spark / scala и сталкиваюсь с проблемой вот код import...
У меня ZonedDateTime как String. Я хочу иметь возможность преобразовать строку в ZonedDateTime с...
Следующий код import scala.language.implicitConversions object myObj { implicit def nullToInt(x:...
Я хочу записать свою коллекцию в файл .parquet, чтобы впоследствии ее можно было прочитать с...
Я обновляю значение ключа в application.conf, устанавливая переменную среды play.http.secret.key=${
Мой код выглядит следующим образом: val y = Seq(("100-200"),("300-400")...
У меня есть этот код и, конечно, во время компиляции у меня есть эта ошибка ... не проверяется, так...
Я написал следующую строку кода, чтобы отфильтровать NULLS из столбца в кадре данных df = df
У меня есть две реализации CodecRegistry для набора классов дел.Большинство из них созданы с...
Я использую Windows-машину и установил Spark и Scala для моего обучения.для spark-sql необходимо...
У меня есть какой-то json, когда я проанализировал, что он возвращает структуру Some (List (Map ..
USE CASE У меня есть список файлов, которые могут иметь допустимый тип MIME или нет.В моем коде я...
import java.util.regex._ object RegMatcher extends App { val str="facebook.com" val...
Следующий простой фрагмент кода содержит while -петл, который выглядит так, как будто он может быть...
Я встречал этого оператора в приложении Spark, написанном на Scala, и хотел бы понять его.Пример ..
Я пытался реализовать SemiGroup универсальным способом для большинства типов scala, включая...
У нас есть код Spark, написанный на Scala, единственное действие - сохранить данные обратно на...
В Databricks я использую следующий код для извлечения данных из Oracle. %scala val empDF = spark
Мне нужна помощь по методам агрегирования, использующим искру с использованием фреймов данных