Можно ли выразить это обобщенным образом, используя кошки или скалязы, это? val common: F[Common] =...

Привет! Я пытаюсь настроить обработку с помощью scala, и я получаю эти ошибки внутри def main ....

Я работаю в Scala с Spark, и у меня есть фрейм данных, включающий два столбца с текстом. Эти...

// class definition of RsGoods schema case class RsGoods(add_time: Int) // my operation originRDD

У меня Spark версии 2.4.0 и scala версии 2.11.12.Я могу успешно загрузить фрейм данных с помощью...

Я использую Spark / Scala для чтения набора данных xml-файлов, выполнения фильтрации и вывода...

Я использую Databricks, и я немного новичок в этом типе работы.Также: если я поставлю это под...

Зависимости включают в себя: com.holdenkarau: spark-testing-bvase_2.10: 1.6.3 org.xerial.snappy:...

Я использую искру на scala. И у меня есть несколько пустых строк в Rdd.Мне нужно удалить их из Rdd....

Я построил akka graph DSL, определяющий простой поток.Но поток f4 отправляет элемент за 3 секунды,...

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

val schema = df.schema val x = df.flatMap(r => (0 until schema.length).map { idx => ((idx, r

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

У меня есть следующий фрейм данных df1 SomeJson ================= [{ "Number":...

Я прочитал файл json и преобразовал его в dataframe в spark. У него есть навык столбца, который...

Я пытаюсь создать индекс на Postgres Table через Spark, а код выглядит следующим образом: val df3 =...

У меня есть метод def getCountryAtPosition(lat: Double, lon: Double) = ???, который явно подвержен...

это моя функция /** * * * @param spark spark * @param templateInfo (code,(type_ids,content,lang)) *...

Это работает: val select = "select code,descrip from table1" val action =...

У меня есть одна карта, такая как val strMap = Map[String, String]("a" ->...

Я пытаюсь преобразовать следующий код в стиль передачи продолжения.Изначально код возвращал String,...

Вот мой вложенный JSON-файл. { "dc_id": "dc-101", "source": {...

Я пытаюсь написать функцию udf в scala и использовать ее в своей работе pyspark.моя схема данных...

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

У меня есть два строковых столбца, разделенных запятыми (sourceAuthors и targetAuthors). val df =...