Я пытаюсь начать использовать плагин макроса Paradise, поэтому я начал с примера макроса...

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

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

Я использую Akka (версия 2.5.18) для отправки строк JSON на определенный сервер через https.Я...

Впервые в spark и java, поэтому, вероятно, будет выглядеть как наивный вопрос. Я пытаюсь запустить...

У меня есть две таблицы mysql: Владельцы и домашние животные Класс дела владельца: Owner(id: Int,...

Я хочу, чтобы игровая среда работала через ipv4 через определенный сетевой интерфейс.Я запускаю...

case class test(primary : String, secondary : Array[String], count : Int) Заданный массив a1: a1:...

Я успешно могу скопировать файл с удаленного сервера Windows на HDFS, используя Jsch jar.Мой...

В настоящее время я пытаюсь проанализировать большой текстовый файл, содержащий один столбец с...

Я управляю проектом Scala, где мне нужно выполнить некоторые правила.Правила будут динамически...

Я создал шаблон scala g8 для kafka streams, но заметил, что он печатается только когда приложение...

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

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

У меня есть вопрос.Есть ли решение, чтобы прочитать этот JSON хорошим способом без потери данных

Я пытаюсь смоделировать некоторые данные с помощью логистической регрессии, части искры MLlib.Для...

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

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

Я использую com.databricks.spark.avro.Когда я запускаю его из spark-shell следующим образом:...

Я пытаюсь использовать Spray-JSON для маршалинга входящего JSON с более чем 22 полями.Поскольку...

Предположим, у меня есть строка как таковая: val a = "aaaabbbcccss" , и я хочу...

Рассматривая граф с 14 000 вершин и 14 000 ребер, я удивляюсь, почему GraphX ​​требует гораздо...

Я бы хотел сделать универсальный скользящий запрос, используя отдельный элемент TableOn для...

Давайте предположим, что у меня есть следующее Dataset: +-----------+----------+ |productCode|...

Я пишу модульный тест для кода Spark Extract, который написан на языке Scala. Я написал модульный...