У меня есть 2 seqOp функции, переданные aggregate, которые я ожидаю получить идентичные результаты....

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

Я всегда понимал, что persist() и cache(), затем действие по активации DAG, рассчитают и сохранят...

Я хочу использовать AWSKmsClient или AWS Encryption SDK с Java для расшифровки зашифрованного...

Я считываю некоторые данные во фрейм данных с сервера Microsoft SQL, используя Spark JDBC. И когда...

Я хочу обобщить интернет-логи, используя sparkstreaming. У меня есть трансформация данные журнала в...

Имея функцию f, определенную как: def f(i1: Int, i2: Int)(i3: Int) = i1 + i2 + i3 С помощью _ можно...

У меня есть два кадра данных df1 и df2, которые имеют следующие структуры: print(df1)...

Как найти количество слов в столбце во фрейме данных? Я пытаюсь найти количество слов в столбце...

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

У меня есть датафрейм, который состоит из имени файла, адреса электронной почты и других деталей....

У меня есть класс дел, который имеет более 22 параметров. case class Model(a1: Int, a2: Int, a3:...

У меня есть особое требование, чтобы заполнить все значения (категории) в столбце.Например, как...

Моя программа Spark сначала определит, существует ли путь к входным данным, и, если это не так,...

Я начинаю работать с Apache Spark (в Windows 10), и все работает не так, как ожидалось.При...

Я пытаюсь написать следующее: import scala.reflect.runtime.universe._ val value: Tree = /* some AST...

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

Недавно я обнаружил, что компилятор Scala имеет интересную особенность для класса case: поскольку...

Я работаю с проектом Scala, который строится с использованием Bazel. Я хотел бы создать Scaladocs...

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

У меня есть файл jar scala с именем SGA.jar.Внутри есть класс org / SGA / MainTest, который...

Недавно я узнал о LMAX Disruptor, и я хочу получить пакет сообщений напрямую, а не получить одно...

Должна ли версия org.apache.kafka / kafka-streams-scala, которую я использую в проекте, быть...

У нас есть требование, когда нам нужно передать имя пользователя и пароль нашего нексуса в команду...

Я пытаюсь настроить поддельный сервер с Play2.7 и средой, предложенной https://developer.lightbend