Я задаю этот вопрос, потому что мое переименование S3 файлов, которые я генерирую с помощью spark,...

У меня есть следующие две части кода, написанные на Scala / Monix: def f1(input) = for { a <-...

Я запускаю небольшую программу в кластере Apache Spark и получаю такую ​​ошибку.Это неправильно.Это...

У меня есть три столбца - «Год», «Месяц» и «Час».Мне нужны входные данные для преобразования его в...

Консоль scala не будет работать, хотя я установил java 8 в качестве версии по умолчанию.Ниже...

Я пишу следующий оператор обновления для базы данных MySql: Orders.filter(_.cookie === cookie)

Я использую Kryo 5.0.0-RC1.У меня есть следующее исключение: java.lang.IndexOutOfBoundsException:...

Я пытаюсь использовать ноутбук Zeppelin с интерпретатором% livy.spark для Ignite.У меня есть...

val dfInput = spark.read .option("delimiter", "\u0001") .csv(file) По умолчанию...

Я работаю с фреймом данных df, он содержит Column массив multi_type [struct], double ... Я хочу...

Я использую Spark со Scala и пытаюсь найти лучший способ сгруппировать Dataset по ключу и получить...

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

Я использую записную книжку Databricks с Spark и Scala для чтения данных из S3 в DataFrame: myDf =...

В Spark, используя Scala, у меня есть набор данных со столбцом, имеющим массив типа [foo, bar, baz,...

Я использую for .. yield в scala для зацикливания объектов типа Future[Try[A]].Реализация for .....

У меня есть ключ redis, в который я вставил данные, используя команду формат как ниже lpush...

У меня есть json, как показано ниже, это всего лишь один фрагмент данных.Таким образом, фактический...

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

У меня есть класс, который вложен в список в другом классе.это выглядит так import spray.json._...

Я пытаюсь применить функцию к Column в Scala, но я сталкиваюсь с некоторыми трудностями. Есть эта...

У меня есть два Array[string] столбца в коллекции MongoDB, теперь я комбинирую их с помощью функции...

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

Мы получили исключение при чтении из файла паркета через искровой фрейм данных. sqlContext.read

позвольте мне начать с того, что я относительно новичок в зажигании, поэтому, если я говорю что-то,...

Как реализовать базовую сериализацию / десериализацию на уровне запросов, используя Doobie , MySQL...