Я новичок в Spark, и у меня есть Apache SparkSQL DataFrame df с 4 столбцами, имеющий следующую...

Я запускаю искровую оболочку с искрой 2.3.1 со следующими параметрами:...

Я получаю исключение ниже в потоке "main" java.lang.UnsupportedOperationException: cannot have...

Я хочу потоковую передачу CSV-файлов на спарк с kafka. Все файлы сохраняются в формате hdf другим...

Моя цель - использовать akka-grpc в моем проекте. С помощью пошагового руководства...

Я новичок в scala и spark, и мне нужно построить график из данных.это структура моего фрейма данных...

У меня есть два класса дел A и AHelper case class AHelper(data: String) { def getData() = {...} //...

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

Я пытаюсь реализовать черту Scala с помощью Java, эта черта имеет общий тип контейнера в другом...

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

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

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

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

Я читаю CSV-файлы с помощью spark и scala, файлы поступают с другого задания потоковой передачи....

У меня есть датафрейм, как показано ниже: +--------+----------------+----+----------+ |role_num|...

Моя программа Scala получает (через tcp) длинный номер, упакованный в python: Python отправляет...

У меня есть два кадра данных, DF1 +----+-------+------+------+ |id | pnl |value2|value3|...

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

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

В любом тексте мы можем встретить сложные слова или объекты, такие как «Университет национальной...

Я пытаюсь прочитать данные из kafka и загрузить их в базу данных greenplum с помощью spark. я...

Я пытаюсь прочитать файл с s3 с моего ноутбука через IntelliJ, чтобы я мог легче разработать свою...

Я хочу использовать личную переменную в моей работе Flink (Scala) для параллельных задач Flink.Мой...

Я написал следующий код scala: val someDF = Seq( | (8, "bat"), | (64, "mouse"),...

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