Я пытаюсь подключиться к удаленному кластеру кассандры в моей искровой оболочке, используя разъем...
Я пытаюсь оценить модель регрессии с градиентным деревом, используя RegressionEvaluator (). Я хотел...
Я подключаюсь к Hbase, используя Spark. Я добавил все зависимости, но все равно получаю это...
У меня есть класс case, определенный в scala как case class Node(key: String, value: String, var...
Я написал следующий простой код: import cats.effect.IO import cats.instances.either._ import cats
Мне нужна помощь в преобразовании плоского набора данных во вложенный формат с помощью Apache Spark...
Я новичок в искре.У меня есть следующая таблица в Кассандре: CREATE TABLE cust_actions ( orgid text...
Я пытаюсь подсчитать появления определенных предметов на определенную дату. Структура моего ввода...
Я хочу преобразовать строку в столбец с помощью искрового фрейма данных. Моя таблица выглядит так:...
В документации написано: enable.auto.commit: источник Kafka не фиксирует никакого смещения....
У меня есть сомнения, связанные с внедрением зависимостей с помощью Google Guice. У меня есть черта...
из Spark RDD, я хочу подготовить и заархивировать данные JSON в AWS S3. Имеет смысл только сжать...
Я пытаюсь понять следующее утверждение из документации: Если конкретный класс объекта неизвестен и...
У меня ошибка в моем коде.Код сбрасывает некоторые данные в базу данных Redshift. После некоторых...
У меня есть набор данных, который содержит двухуровневую строку JSON. Вот пример того, как выглядит...
Я использую эту команду для запуска своей работы на спарке. spark-submit --class=ueba.Main --jars...
У меня есть два кадра данных df1:...
Я вставляю данные в таблицу улья с итерациями в искре. Например: скажем, 10 000 элементов, сначала...
Итак, у меня есть значение FFD8FFE0 (подпись jpg / jpeg), и я хочу проверить, является ли...
У меня есть следующие классы import spray.json._ sealed trait Base case class Foo[K, V](key : K,...
Итак, у меня есть 2 строки val a : String = "foo April 06 1994 bar" val b : String =...
Если у меня есть JSON {"name":"jack","email":"jackt@gmail
Я реализую SparkHealthListener, расширяя класс SparkListener. @Component class...
У меня есть фрейм данных со следующей схемой: root |-- e: array (nullable = true) | |-- element:...
UDF - мне нужно пройти через фрейм данных, чтобы выполнить определенную операцию. Я понимаю, что не...