Я использую Scala для запуска этого проекта , код выглядит следующим образом: package com

У меня есть датафрейм, который выглядит следующим образом: df: col1 col2 a [p1,p2,p3] b [p1,p4]...

У меня есть датафрейм id lat long lag_lat lag_long detector lag_interval gpsdt lead_gpsdt 1 12 13...

У меня есть фрейм данных со столбцом массива. val json = """[ {"id": 1,...

Я новичок в скале.Пожалуйста, наберитесь терпения. У меня есть этот код. import org.apache.spark

Я запускаю программу spark в scala и получаю ошибку ниже времени выполнения: Exception in thread...

Я наткнулся на следующий код scala: val x = 10 match { case _: Int => data: Any =>...

var versionMap = scala.collection.immutable.Map.empty[String, List[String]] var queryType =...

Я пытаюсь определить схему для файла CSV, используя case class в Scala. case class userSchema(name...

Привет, поэтому у меня есть черта, которая принимает некоторое представление о себе как параметр...

Я пытаюсь решить проблему и получаю результат в формате Map [String, (Double, Double)]. Мне...

У меня есть 2 кадра данных: |data | |--------------| |[1,Rob,12] | |[2,Jeremy,11] | |[3,Bart,14] |...

У меня есть фрейм данных следующего формата: name merged key1 (internalKey1, value1) key1...

У меня есть набор данных транзакции, который я готовлю к val df = spark.read.parquet(".

Я новый ученик, я хочу посчитать количество разных слов из файла. Это отлично работает val filePath...

Мой скалярный код Spark выглядит так: val input = sc.newAPIHadoopRDD(jconf, classOf[CqlInputFormat]...

У меня есть следующая схема данных: root |-- firstname: string (nullable = true) |-- lastname:...

Мне нужно отфильтровать только текст, начинающийся с> в столбце. Я знаю, что есть функции setsWith...

У меня есть несколько идентичных схем, но когда Slick генерирует классы, он жестко кодирует там...

Мне нужно перебрать список и сравнить предыдущий элемент списка с текущим.Исходя из традиционного...

Я пытаюсь подключиться к Vertica dB с помощью Spark v2.3.1 Scala 2.11.8 с использованием jdbc. На...

Spark имеет полезный API для накопления данных безопасным для потоков способом https://spark.apache

У меня такая ситуация: метод a: создается неявный ec метод a: вызывает другой метод в будущем,то...

Я хочу выбрать несколько столбцов из DF. Между столбцами мне нужно добавить разные пробелы, так как...

Вчера (практически полный журнал) Я попытался найти элегантный способ представления модели с...