Я изменил свою версию akka-stream-kafka с 0.11-M2 до 0.17, для этого также потребовалось, чтобы...

У меня есть DF, как показано ниже: | value |offset (these 2 are columns)...

Я пытаюсь создать конвейер данных с использованием spark и scala в Maven Project. Данные поступают...

Я пытаюсь разработать бинарную древовидную структуру в Scala, но у меня есть ошибка, которая...

У меня есть программа spark (scala). Я запускаю сборку команд, чтобы получить банку. Я поставил...

Я новичок в Spark. Может ли кто-нибудь помочь мне понять, почему создание SparkSession следует...

val xml = <foo> <bar>hi world</bar> <bippy>how's it going...

Мне нужно импортировать файл CSV, который содержит несколько полей, позже я должен выполнить цикл...

1) У меня 32 раздела в EventHUB. 2) я хочу начать чтение с определенного seqNO для всех этих 32...

Я пытаюсь прочитать файл csv в фрейм данных из AWS S3 с использованием потоковой передачи Spark,...

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

Сначала код: object MyEnums { sealed abstract class MyEnum(val value: String) case object First...

Я знаю, как сделать эту Scala Spark - интересно, почему в Анаконде так больно - Питон Я хочу...

Я пытаюсь выполнить массовую вставку в таблицу SQL Server из записной книжки, используя метод,...

У меня есть данные, как показано ниже.Содержит идентификатор продукта, стоимость изготовления,...

У меня есть карта записей типа Map [String, String] и карта поиска типа Map [String, Map [String,...

Я объявил объект Sparksession в классе scala. Выдает ошибку "не найдено: значение SparkSession" ...

SCALA Мой вложенный JSON появился, как показано ниже. {"event":"movie"...

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

Я использую spark 2.3.2 и сталкиваюсь с проблемой создания объединения двух или более потоковых...

Я читаю XML-файл в Scala <tag1> <tag2 id="0" attr1="abc" ... /> .....

Мне нужно найти способ вычислить обратную матрицу некоторого типа распределенных данных в Spark....

У меня есть метод, определенный ниже, и я хотел бы объединить сопоставление с образцом. Оператор or...

Эй, ребята, я новичок в Spark / Scala, и я хотел переименовать несколько вложенных полей JSON,...

Мне нужно проверить типы данных DataFrame. Образец DF val rawData = Seq((1,"First Rec Col...