Я пытаюсь прочитать ответ с URL-адреса, отправляющего тело JSON. Но мой код не может прочитать...
Мне было интересно, какая из двух возможностей предпочтительнее.На мой взгляд, они делают более или...
У меня есть многоузловой кластер Spark cluster. Я создаю журналы, используя log4j. Журналы...
Версия Spark: Scala 2.12.8 (Java HotSpot(TM) 64-Bit Server VM, Java 1.8.0_211) В следующем коде...
Я новичок в Скале. Разработка моего первого приложения для Scala с Akka-grpc. Я определил свой...
У меня есть СДР следующим образом: [(((1, 2), 1.0), (2, 3)), (((1, 2), 1.0), (3, 4)), (((1, 2), 3
Какое соглашение об именах в Scala для функции, возвращающей результат, заключено в Future? Я видел...
У меня есть сценарий использования, возможно, не специфический для Слика, а для понимания. Шаблон...
Я пытаюсь получить доступ к каждой строке определенного "числа" столбца Int, чтобы проследить...
Я загружаю свой CSV-файл во фрейм данных, и я могу это сделать, но мне нужно пропустить начальные...
У меня есть приложение Scala Spark, для которого я хочу создать jar с зависимостями, используя...
Я сталкиваюсь с множеством классов, требующих kryo регистрации. Существует ли регистрация по...
Простое val postsAndUsers = posts.join(users, $"_OwnerUserId" === users("_Id"),...
Я использую такой код: spark.read.format("jdbc").options(Map("url" ->...
У меня есть библиотека, в которой я использую log4j для записи вещей.Для некоторых конкретных...
Я работаю над заменой метода unapply на объекте-компаньоне класса case моей собственной реализацией
Я проверяю код разработки и мне нужно избегать или использовать другой способ добавления столбцов с...
, когда я пытаюсь создать следующий пакет с помощью sbt package: import org.apache.spark.sql
Я использую slick с slick-pg с намерением использовать возможности json.Я создал определение...
Я использую onStageCompleted из SparkListener, пытаясь извлечь некоторые полезные данные из...
Я использую Slick 3.3.0, и у меня есть сценарий использования для обновления таблицы паролей, но...
Я пытаюсь превратить объект Scala (т.е. класс case) в байтовый массив. Чтобы сделать это, я...
Я пытаюсь прочитать файл из hdfs, используя scala, но я получаю следующее исключение, когда...
Я использовал show partitions в spark sql, что дает мне следующее: year=2019/month=1/day=21...
Я запускаю простой проект Spark в кластере EMR YARN, чтобы: прочитать текстовый файл на S3 в...