мой вход - это фрейм данных Spark: EventTime,Signal 0,-65 10,-63 20,-71 40,-65 50,-62 80,-81 90,-84...

Это моя функция применения правила, изменения столбцов mdp_codcat, mdp_idregl, usedRef в...

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

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

У меня есть сценарий использования, где мне нужно записать в базу данных postgres из spark, Я...

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

Я новичок в Apache Spark, а также в Scala, в настоящее время изучаю этот фреймворк и язык...

Предположим, у меня есть org.apache.spark.sql.DataFrame с этой схемой: root |-- origin: string...

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

Я использую zipWithIndex, чтобы сгенерировать sequence_number и добавить его в виде отдельного...

Я хочу создать Spark DataFrame df одним из двух возможных способов: val dataSourceType =...

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

Если у меня есть записи ниже {"A",7} {"B",10} {"C",10} Тогда...

Я хочу выполнить запрос GET к сайту HTTPS в playframework (2.4.8) со следующим кодом: val...

Описание проблемы Scala StringOps предоставляет метод lines, который возвращает Iterator[String]

Я пытаюсь загрузить таблицу из базы данных MS Access. Я делаю это так: val table = sparkSession

У меня есть следующая функция в Scala: def getData(spark: SparkSession, indices: Option[String]):...

Когда я запустил свой искровой код: val sqlContext = spark.sqlContext val noact_table =...

У меня есть датафрейм userdf как val userdf = sparkSession.read.json(sparkContext

Я пытаюсь запустить частную сеть блокчейнов wave в Windows 10. После выполнения некоторых...

Допустим, у меня есть код: val data = """^0001|1|0|813|1|860152033876093|

Я пытаюсь разработать интеграционное тестирование.Я буду запускать несколько jar-файлов, написанных...

Я хочу преобразовать array: String в Seq[Message] ... Класс дела: case class Message(name: String,...

Впервые в Scala, я хочу попробовать переписать некоторый код в flatMap, вызвав функцию вместо...

Используемые версии: Версия Spark: 2.3.2 Версия Scala: 2.11.8 Версия SBT: 1.2.4 build.sbt: name :=...