У меня есть Scala DataFrame (df) со столбцом типа date dt:date column1:string Я пытаюсь...

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

У меня есть Dataframe со строковым ключом и строковым значением JSON. Идея состоит в том, чтобы...

Я столкнулся с несколькими источниками информации, такими как найденный здесь , который объясняет...

Я пытаюсь развернуть приложение Scala 2.12.0 + Spark 2.4.4 в AWS EMR. У меня Spark 2.4.4 включен в...

Я извлек некоторые данные из улья в датафрейм в указанном ниже формате....

Цель Цель, которую я хочу достичь, - прочитать файл CSV (ОК) закодировать его в...

Я пытаюсь интегрировать ignite в мое искровое потоковое приложение с поддержкой искр. Ниже...

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

Я использую Spark 2.4, и у меня есть искровой фрейм данных, который имеет 2 столбца - id и...

Я проводил исследование о настройке Spark JobServer Backend (SharedDb) с Cassandra. И я видел в...

Я работаю с данными об отношениях и мне нужно найти дедушку (с минимальной датой рождения) для всех...

Я создал кластер Raspberry pi с установленными Spark и Hadoop и сделал несколько функций в .bashrc,...

У меня есть обученная модель keras. https://github.com/qubvel/efficientnet У меня большой...

Я пытаюсь использовать структурированную потоковую передачу с Apache Bahir и Spark. Из исходной...

Мне нужно вызвать службу отдыха для каждого ряда набора данных в искре. Я создал следующий код:...

Я пытаюсь создать zip-файл из нескольких файлов. Например, у меня есть 3 файла file1 file2 file3 Я...

Итак, у меня есть этот фрейм данных, который выглядит следующим образом:...

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

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

Есть ли способ создать XML SOAP REQUEST, извлекая несколько столбцов из каждой строки кадра данных?...

Команда println( sql( "SELECT date_format(now(),'yyyyMMdd')" ).as[String].first...

при отправке искрового задания в автономном режиме оно сразу же завершает работу, сообщая об ошибке...

Как я могу объединить или объединить статический фрейм данных только с одной строкой в ​​потоковый...

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