Я пытаюсь сохранить свои объекты DateTime, такие как типы DATETIME, в базе данных. До сих пор я не...
Я пытаюсь передать metrics.properties свече emr: оставить ее в папке resource работает только...
Я работаю со Scala и Spark, и я относительно новичок в программировании на Scala, поэтому, возможно...
Я запускаю приложение spark grep на своем 1-узловом кластере искр. (Сам хозяин и раб). У меня есть...
У меня есть List [String], как показано ниже val colList = List(verifyLength($"col1",...
У меня есть следующая функция, которая выравнивает последовательность отображений строки, чтобы...
Я хочу использовать кэш в памяти в моем задании Flink (Scala), чтобы я мог установить TTL (время...
Мне нужно создать фрейм данных с n строками, и каждое значение столбца строки инициализируется...
Я пытался составить три функции, из которых только средняя была PartialFunction. Я ожидаю, что...
Мне нужно сравнить две коллекции типа ArrayBuffer[Array[String]], используя чисто функциональное...
import io.circe.generic.extras.{Configuration, ConfiguredJsonCodec} @ConfiguredJsonCodec case class...
Я использую Slick 3.3.0 с Scala 2.12.8 и пользовательский метод def * для класса с более чем 22...
На моем ноутбуке работает докер-контейнер с мастером и тремя рабочими, я могу запустить типичный...
У меня есть склеенная работа (Spark job), написанная на Scala, и я хотел бы передать в нее...
Данный фрейм данных: +-----------------+---------+-----------------+ | user_id| id|...
У меня есть список RDD [(String, List [Int])], подобный List ((«A», List (1,2,3,4)), («B», List (5...
Я посмотрел на этот вопрос: Вопрос о присоединении фреймов данных в Spark и ответил на него,...
Я новичок в Scala, и у меня есть случай, когда я пытаюсь извлечь определенный столбец в кадре...
Этот вопрос является продолжением этого другого , где пользователь который дал правильный ответ,...
Я хочу преобразовать ниже объект XML, val xml = <body> <para>first</para>...
У нас есть наш HTTP-слой, обслуживаемый Play Framework в Scala. Один из наших API-интерфейсов имеет...
Я написал следующую функцию в Scala, которая работает: import java.text.SimpleDateFormat import...
В Spark вы можете сделать setName на СДР. Можно ли загрузить СДР от имени? Как и spark
Я получаю следующую ошибку при запуске следующей команды через spark-shell. Я также добавил банку...
Я занимаюсь разработкой приложения, которое создает актеров Akka для управления и обработки...