Я устанавливаю zipkin, используя docker , затем я получаю к нему доступ, используя...

Привет, я написал этот код ниже в scala spark, при запуске с 6,4 миллионами записей, я получаю эту...

Я работаю с Yelp Academic Dataset , и я взял небольшую выборку из проверочных выборок, чтобы...

Вот JSON , который необходимо преобразовать { "name": "Jon", "tags":[...

Я пытаюсь передать сжатый файл, используя IOUtils.copyLarge.Когда я перехожу с GZIPInputStream на...

Я пытался запустить приложение Scala в jar. Следующий код: object Starter { def main(args:...

Я новичок в программировании Spark, и мне нужно выполнить некоторые тесты для функций sampleByKey и...

Мы переносим наши программы Scala Spark с 1.6.3 на 2.2.0.Рассматриваемая программа состоит из...

Кто-нибудь знает какую-либо возможную причину, по которой событие добавления метода в...

У меня есть две строки ниже "key1, c1, p1,10, t1, z1" "key2, c2,20, p2, t2" И я хочу вывод какниже...

Я новичок в скале и искре.Я импортировал CSV, как показано ниже, и хотел использовать его в Spark...

У меня есть граф dse в среде валидации / тестирования.Проблема возникает, когда я пытаюсь запустить...

Я пишу макрос, который генерирует некоторый код, подобный этому: q"_root_.ru.lmars.macropack

Я создаю POC, где я пытаюсь загрузить зависимости из моего корпоративного репозитория (JFrog), где...

У меня есть класс: class DataLoader { def rdd2RddTransform( ss: SparkSession, inputRDD:...

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

В настоящее время скользкий запрос: (for { t <- userType if t.user_type === uType h <- hand...

Мы используем инструмент Avrohugger для создания файла класса scala из схемы Avro.Но файлы классов...

Итак, я столкнулся с проблемами с дисковым пространством во время продолжения обработки задания...

Мне нужно добавить некоторые метаданные об источнике данных, прежде чем возвращается DataFrame.Я...

Мне интересно, почему сообщения печатаются в том же порядке, что и в коде. import akka.actor

Итак, я пытаюсь зациклить в Scala.Код ниже val x = 5 for (x <- 1 until 10) { println("the...

Я пытаюсь использовать библиотеку Scala XML во Flink для анализа XML, и я не могу заставить ее...

Я создал программу Scala для применения k-средних в определенном столбце данных.Имя кадра данных:...

Я пытаюсь закодировать объект protobuf (подготовленный scalapb) и передать его другому сервису,...