Я попытался построить очень простую сущность и сохранить ее в БД, используя Hibernate 5.4.1.Final и...

Я пытаюсь воспроизвести этот запрос в Slick. SELECT * FROM A JOIN LEFT B AS B1 ON B1.aId = A.id...

Я новичок в Spark Framework и мне нужна помощь! Предположим, что первый DataFrame (df1) хранит...

Я получил фрейм данных (df) этого формата. df.show() ******************** X1 | x2 | X3 | ..... | Xn...

Я использую Scala 2.12.6 и У меня есть класс Alert, который выглядит следующим образом: case class...

У меня довольно простой DataFrame. val df = Seq( ("Alex", "2018-01-01 00:00:00"...

Учитывая следующее, что работает нормально: myDF.as[MyCaseClass].sort("process_utc_sec")...

С динамической генерацией столбцов хорошо работает следующее: import org.apache.spark.sql.functions

Сначала у меня было salesList: List[Sale], и чтобы получить идентификатор последней продажи в...

Когда мы используем spark для чтения данных из csv для БД следующим образом, он автоматически...

Учитывая, что у меня есть фрейм данных с некоторыми столбцами: Почему это не работает? val output3b...

Я создал простой проект в Graphx, как только я пытаюсь запустить этот тестовый проект, я получаю...

Я ищу, чтобы сохранить весь Dataframe в цикле foreachpartition на Cassandra. Я знаю, что могу...

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

Я пытаюсь прочитать несколько путей за один вызов в Spark API в Scala с помощью метода .parquet. У...

Я новичок в Scala, здесь я пытаюсь найти четные числа от 1 до 100, поэтому во время фильтрации я...

Я использую sttp клиент.Я хочу интерпретировать ответ как строки, разделенные на строки, например...

У меня есть следующая схема - root |-- id:string (nullable = false) |-- age: long (nullable = true)...

При использовании scala 2.12.8 это не скомпилируется без приведения: trait Content case object A...

Я пытаюсь создать структурированный поток из Кафки в Spark, который представляет собой строку json

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

У меня есть модульный тест, который в основном преобразует фрейм данных в набор данных, используя...

Я пытаюсь выяснить, как Lagom можно использовать для получения данных из внешних систем,...

Я пытаюсь разбить мой основной Dataframe (dfData) на умноженные полу Dataframe без повторного...

Предоставленный фрагмент кода представляет собой вымышленный минималистический пример,...