Теперь у меня есть простой пустой фрейм данных, созданный как import org.apache.spark.sql

Я создаю 3 объекта GregorianCalendar: 4 декабря 2018 года 4 декабря 2018 года + 96 дней 4 декабря...

У меня есть плоский фрейм данных (df) со структурой, как показано ниже: root |-- first_name: string...

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

Я хотел бы вставить объект json в scala с использованием ячейки Hbase, в настоящее время я могу...

я хорошо запускаю отправку spark с --master local[*], , но когда я запускаю отправку spark на моем...

Я не эксперт в спящем режиме, но я пытаюсь выучить это с помощью Scala.До сих пор я мог только...

Я пытаюсь отфильтровать nscala-time DateTime с Slick package models.repositories.tables import java

rdd1: (m1,p1) (m1,p2) (m1,p3) (m2,p1) (m2,p2) (m2,p3) (m2,p4) rdd2: (m1,p1) (m1,p2) (m1,p3) (m2,p1)...

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

У меня есть следующий код Scala Spark для анализа txt-файла фиксированной ширины: val schemaDf = df

Я пытаюсь добавить столбец в фрейм данных, который будет содержать хэш другого столбца . Я нашел...

Я пытаюсь объединить заголовок в один выходной файл как csv ( ref от @Kang) import org.apache

Мы пытаемся добавить поддержку TLS для Tcp в Akka, используя BidiFlow.Нам удалось установить...

У меня есть одна программа, которая ожидает CSV-файл и написана на Python. Предполагается, что...

Я пытаюсь определить метод toList внутри черты следующим образом: sealed trait Stream[+A] { def...

Как я могу изменить приведенный ниже код так, чтобы он извлекал только последнюю строку в таблице,...

Когда я использовал Spark, чтобы прочитать файл CSV и преобразовать его в набор данных, я получил...

Я пытался удалить дублирующийся код в Scala, но безуспешно. Что у меня есть: (table

У меня есть входной фрейм данных, где я хочу сделать перевод с похожим типом записей в одну запись

Я получаю ошибку времени компиляции в программе scala spark для метода filter.Ниже мой код: case...

Я собираю пакет для своей программы scala. Я импортировал пакеты, проверил зависимости библиотек и...

Как описано в заголовке, как я могу присвоить значение переменной rdd? Мой код выглядит так: Var...

У меня есть следующая функция Scala, которую я зарегистрировал как UDF в Azure DataBricks (Spark 2

Учитывая этот график: Примерный график Как получить все связанные вершины из vertexID? Например, из...