Моя цель - извлечь данные из Kafka с помощью Spark Streaming, преобразовать данные и сохранить их в...

Я немного новичок в Scala и Spark, поэтому не стесняйтесь судить меня, но не слишком сложно. Я...

Я пытаюсь использовать UDF и возвращать ListBuffer в качестве столбца из UDF, получаю ошибку. Я...

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

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

У меня есть список scala List[Any] = List("a", "b",...), и мне нужно получить...

В отличие от предварительных версий искры, таких как предыдущая потоковая передача искры, в...

Я новичок в Spark, установил Spark на мой компьютер с Windows и выполняю команду spark в...

При загрузке CSV-файла, определяющего схему, где некоторые поля помечены nullable = false, я ожидаю...

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

У меня ниже образец данных: 67832,CLARE,MANAGER,68319,1991-06-09,2550.00,,1001 65646,JONAS,MANAGER...

У меня есть этот вектор: val imageIds = Vector( "XXXX1", "XXXX2",...

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

У нас проблема с JavaFX MediaPlayer уже более месяца.Мы прочитали и попробовали все подобные...

Я озадачен этим фрагментом кода, и мне интересно, является ли это ошибкой искры.Мне удалось сузить...

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

РЕДАКТИРОВАТЬ: Добавлено в информации о F[_] Вот настройки.У нас есть родительский класс, который...

Я новичок в скале и искре.Я получаю ошибку компиляции на intellij для следующего оператора, который...

c1,c2,c3 pencil,book,eraser pen,book если это мой набор данных, мне нужны такие комбинации, как...

Я новичок в Scala и AWS Glue. У меня есть файл CSV, загруженный на S3, и у меня есть другая таблица...

Учитывая огромный набор данных о событиях, каждое из которых имеет свое время начала и окончания...

val Match: (String) => Double = (address: String) => { val address = if (address == null)...

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

Допустим, у меня определено будущее, как показано ниже: import scala.concurrent.Future def...

У меня есть конечная точка, которая принимает специально отформатированный XML.Я пытаюсь...