Предположим, есть 3 числа: val x = 10 val y = 5 val z = 14 и мы хотим сделать логику вроде: if (x +...

Я пытаюсь запустить sql-запрос hive в приложении spark scala и получаю следующую ошибку «Нет плана...

Мне нужно знать, возможно ли удалить строки таблицы в Oracle Database с помощью Spark. Как, я хочу...

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

Код: val badData:RDD[ListBuffer[String]] = rdd.filter(line => line(1).equals("XX") ||...

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

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

Я заметил, что контейнеры типа Option, OptionT, fs2.Stream имеют следующий метод: def collect[B](f:...

Я новичок в Streaming Framework Spark и пытался обработать поток Twitter. Я нахожусь в процессе...

Я создаю настольное приложение Scala, требования: Java 8 (не 9, не 10, не 7) Использование Scala...

Итак, я искал документацию об основных различиях между parametric polymorphism и adhoc-polymorphism...

Я заблудился в rx.Observable API и мне нужна помощь. Я бы хотел удалить большую часть документа в...

Когда я записываю фрейм данных, скажем, в csv, файл .csv создается для каждого раздела. Предположим...

Недавно я слушал видео Мартина Одерского, где он пытается объяснить фундаментальное преимущество...

Я пытаюсь решить следующую проблему: входной фрейм данных: +------+------+------------+ |emp |Group...

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

Как объяснено в этой статье , Взрыв происходит медленно в scala 2.11.8 и искре 2.0.2 . Не переходя...

Я использую следующую функцию для разбора URL, но она выдает ошибку, val b =...

Я пытался написать простую реализацию flatMap для Either sealed trait Either[+L, +R] { def...

Я пытаюсь изменить значение массива на основе значения другого массива. В частности это массивы, с...

Я работаю с фреймом данных root |-- c: long (nullable = true) |-- data: array (nullable = true) |...

Я пытаюсь удалить символы новой строки из столбцов строки Dataframe, используя foldLeft &...

Я пытаюсь перечислить все так называемые folders и sub-folders в поле s3.Теперь, когда я пытаюсь...

Моя основная функция определяется следующим образом: def rowToSHA1(s: Seq[Any]): String = {...

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