Есть несколько базовых классов и бесов: abstract class BaseClass(@transient spark: SparkSession)...
Я пытался проанализировать имеющиеся у меня вложенные данные JSON, изолировать объекты в массиве и...
def main(args: Array[String]): Unit = { var url = "jdbc:mysql://localhost:3306/spark
Я (новичок в Play и Scala) попытался настроить сборку Play + Scala с помощью приложения sbt.Сервер...
С учетом следующего случая: trait Companion { implicit def str(a: A): String = s"${this
Я новичок в зажигании Скала. Как мы можем обрабатывать xml в текстовом файле вместе с другими...
Я создаю несколько тензоров в цикле и хочу объединить их все в один объект тензора тензоров.Я думаю...
У нас есть требование для автоматической загрузки журналов SSN в хранилище BLOB-объектов.Я...
Почему rundeck не запускает запланированные задания запуска, даже если предыдущее задание все еще...
val SCHEMA : Schema = .... dStream.map(b => deserialize(bytes)) def deserialize(b: Array[Byte]):...
Я хочу добавить некоторые параметры в мое приложение spark & Kafka для записи Dataframe в тему...
Мы написали модульные тесты для искры в локальном режиме с 4 потоками. При запуске по одному,...
Я пытаюсь реализовать пользовательские журналы приложений, создав файл log4j.properties с...
У меня есть фрейм данных, в котором я хочу отобразить минимальное значение в _c3 для...
Мне нужно привести столбец фрейма данных, содержащий значения в виде всей строки к определенным...
У меня есть старый проект Play Framework, названный old-project, с routes файлом GET /something...
У меня RDD как Array[(a, b), (a, c), (a, d)]. Я хочу отобразить его как ((a, b), 1), ((a, c), 1),...
У меня есть тип безопасной конфигурации Config, который содержит тип данных карты. Ниже приведено...
Я новичок в Скале. Я пытаюсь записать вывод в файл, используя sparkJob. Сгенерированные файлы имеют...
Предположим, что у меня есть класс с именем Rational, который представляет рациональные числа...
Соединение двух фреймов данных, Команда, Капитан, Match_ID A, Jack, 13 A, Jack, 14 A, Sam, 15 B,...
У меня есть следующий DataFrame df в Spark: +------------+---------+-----------+ |OrderID | Type|...
Я недавно загрузил Scala IDE для Eclipse для проекта Spark / Scala. Для этого я создал проект Maven...
У меня есть довольно простой пример, когда одна функция foo(), которая принимает неявный аргумент...
Скажите, что у меня есть следующее для понимания: val validatedInput = for { stringID <-...