var result_df1 = result_df.select(result_df.columns.map(c => col(c).cast(StringType)): _ * ) Это...

У меня есть такой класс дел: case class ColorDetail( color: Option[Color], shades: List[Shade] ) У...

Предполагая, что у меня есть следующий DataFrame: +---+--------+---+----+----+...

Я получаю несоответствие типов со следующей ошибкой: Type mismatch, expected: Color, actual...

Мне интересно, можно ли запросить веб-службу API с помощью Spark Streaming. Я уже разработал...

Мне нужно вызвать метод, который возвращает Option[List[Obj]]. После того, как я позвоню, мне нужно...

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

Используя scala для справки, мы видим откат (orElse) в нескольких местах, таких как PartialFunction...

Я новичок в Spark-shell и получаю эту ошибку при создании кадра данных из csv файла: scala> val...

У меня есть данные: {CurrentDate:05.24.2008,Employeeid:90786532432,Division:TX_VG} {Division:NW_VG...

Я читаю файл CSV в dataframe1, а затем фильтрую некоторые столбцы в dataframe2, при выборе столбцов...

У меня есть таймер, который запускается каждые x секунд (интервал времени). Теперь я хочу позвонить...

Вот структура: - Точки - сегменты - дорожки case class Point(name: String, x: Long, y: Long) case...

Я пытаюсь создать общую матрицу в Scala, используя класс case. Я пишу здесь, потому что я был бы...

Я хотел бы преобразовать это: @select( telephoneForm("service.id"), options(services),...

Так что я недавно перешел из ScalikeJDBC в Quill в своем проекте scala из-за поддержки...

У меня есть сотни тысяч небольших паркетных файлов, которые я пытаюсь регулярно читать в Spark. Мое...

Мне интересно, как у меня может быть два абсолютно одинаковых этапа, несмотря на то, что я кеширую...

Я хочу использовать scala для чтения Hbase от Spark, но я получил ошибку: Exception in thread...

Как объединить простой (то есть без вложенных структур) фрейм данных в список? Моя проблема...

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

Я заметил, что компилятор scala не разрешает перегрузку метода области видимости. Версия Scala 2.11

У меня есть фрейм данных с 20 столбцами и 25 записями (небольшие стандартные данные. Размер файла =...

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

Я создал объект Stream следующим образом: object Stream { def cons[A](hd: => A, tl: =>...