Я хочу прочитать некоторые данные из Рadoop напрямую из spark worker: Итак, в программе spark у...

Я пытаюсь прочитать, что таблица HIVE содержит данные за 2 года и разбита на сутки, чтение через...

Могу ли я сравнить keyedDataStream с keyedPatternStream? Если это так, пожалуйста, кратко,...

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

У меня есть задание Spark, которое использует данные из защищенной темы Кафки. Это работает, когда...

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

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

Я использую шаблон pub-sub в fs2. Я динамически создаю темы и подписчиков при обработке потока...

Если бы я хотел сопоставить шаблон с базовым типом опции в Scala, я бы запустил что-то вроде val...

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

Допустим, у меня есть некоторый код, который использует List def processList(input: List[Int]):...

Я хочу прочитать некоторые файлы схемы json из AWS S3 и преобразовать их в Spark StructType. У...

У меня есть запрос postgres, который использует функцию array_agg() для возврата значений PgArray....

Могу ли я оценить искру в наборе инструментов Scala? Мне нужно что-то прочитать с помощью spark на...

Как получить доступ к строкам из C в GraalVM? Я приложил пример в Ada, где экспортируется функция...

Я пишу макрос, чтобы получить определение val/var. Я могу получить вмещающий символ val/var, но не...

Я работаю над старым проектом, который был написан на Scala с использованием SBT. Модульные тесты...

Я пытаюсь сохранить Dataframe в папку HDFS. Но мое спасение занимает много времени. Действие до...

val a = keyedPatStream.map(_._1)//String val b = keyedStream.map(_._1)//String val c =...

Я хотел бы удалить более ранние сообщения от актера. Основная идея состоит в том, чтобы иметь...

Я создаю набор данных при использовании класса дела. case class employee (emp_id: Integer,...

Я пытаюсь объединить несколько файлов паркета в несколько каталогов, используя Spark scala. Код...

Я выполняю первую задачу со следующего веб-сайта https://www.freecodecamp

У меня есть Scala-код, который преобразует слой в файл Geotiff. Теперь я хочу, чтобы этот файл...

У меня есть 2 потока kafka один (keyedStream) для DataStream позже (keyedPatStream) для Pattern...