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

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

Можно ли использовать Amazon 2.4.2 в качестве механизма исполнения с кустом 2.3.4 в Amazon EMR? Я...

Я прочитал несколько статей (также книгу Functional domain modeling), где они предлагают отделить...

Я хочу создать класс case динамически, и для этого я написал программу, но не смог определить класс...

Я хочу установить контрольные точки внутри foreach через равные промежутки времени в ядре Spark....

CodeWars снова бросает вызов.Сегодня у меня есть проблема с этим: "Ваша задача состоит в том, чтобы...

def csvReader(readCsvdf:DataFrame):Dataframe= { val readCsvDf= spark.read .format("csv")

Мне нужна помощь, чтобы понять итерацию в 'scala'.У меня есть фрейм данных, который имеет другой...

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

Я разрабатываю приложение с использованием scala для загрузки зашифрованного файла из GCS...

У меня есть приложение Spark, написанное на Scala, которое пишет и читает файлы Parquet. Приложение...

Я предварительно обрабатываю свои данные (2000K + строки) и хочу подсчитать дублированные столбцы в...

У меня есть data.txt файл, как показано ниже. 12, 345, 6789 Теперь я хочу выполнить начальное...

Хотя я очень предпочитаю использовать прямое SQL вместо DSL, есть случай, когда требуется...

Рассмотрим определение одиночной функции , найденной в бесформенном репо: /** Polymorphic function...

Пожалуйста, предложите лучше всего реализовать следующий код: Требование : передать одну строку или...

Я использую GraphX ​​для моделирования шоссе. Каждая вершина является точкой дороги, и каждое ребро...

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

Я получаю сообщение об ошибке ниже, когда пытаюсь составить список больших двоичных объектов,...

Предположим, у меня есть foo: A => Try[B] и я хочу запустить его асинхронно с Future, например...

Я получаю ошибки, компилируя следующий пример кода. abstract class Base case class A(i: Int)...

У меня есть простой объект Scala, который создает RDD, а затем собирает и распечатывает все...

У меня есть датафрейм, df2, такой как: ID | data -------- 1 | New 3 | New 5 | New и основной кадр...

Я разработал приложение для Scala и получаю из него почти правильные результаты. Но я не уверен,...