Я разделяю «split_column» на еще пять столбцов в соответствии со следующим кодом. Однако я хотел,...

Допустим, у меня есть: trait X { val x: String } Используя миксин, я могу определить такую ​​черту,...

Я работаю с фреймом данных df.printSchema() root |-- key_value: struct (nullable = true) | |-- key:...

У меня есть CSV-файл, содержащий названия стран и годы, которые они выиграли на Евровидении:...

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

У меня есть работа с scala spark для записи в s3 в виде файла паркета. Пока это 6 миллиардов...

Чтобы перебрать столбцы в Spark Dataframe, созданном из таблицы Hive, и обновить все вхождения...

У меня есть следующее: def myFunc(str: String): Something => { str match { case "a" |...

Что такое концепция «параллельных коллекций» в Spark, и как эта концепция может улучшить общую...

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

Это взято с 6-й недели из курса функционального программирования Coursera в Scala. Я пытаюсь...

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

я наткнулся на этот код: val f = Future { throw new InterruptedException } f.failed foreach { case...

У меня есть несколько графиков одного типа. Я хочу хранить их в массиве. Но когда я добавляю граф в...

Я читаю данные из файла для создания ребер графа. Я объявил массив и добавил ребра по одному. Этот...

Мне нужно использовать следующие библиотеки - import org.apache.spark.SparkConf import org.apache

Предположим, в качестве примера, я хочу функцию, которая рекурсивно оборачивает массив в другой...

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

Моя среда - Spark 2.1, Scala Это может быть просто, но я ломаю голову. Мой Dataframe, myDF похож на...

Я передаю тип в плоскую карту следующим образом; val customData: RDD[(Text/String, Custom)] =...

Storm Версия: 1.2.1, Версия Java: 8 Я пишу топологию шторма в scala и начал получать следующую...

Я получаю эту ошибку при запуске коннектора Spotify Spark Bigquery на платформе данных Qubole. Я...

Допустим, у меня есть: val sayHello: Int => Unit = {_ => println("hello")} val...

У меня проблемы с попыткой обработки огромного количества данных в кластере. код: val (sumZ,...

Я пытаюсь обучить алгоритм ALS на Spark-Submit, сохраняя модель на HDFS и ее прогнозы на Cassandra...