У меня есть программа, пытающаяся подключиться к базе данных Neo4j и запустить на Spark, testApp
Мне нужно записать во внешний кластер HDFS, данные аутентификации которого доступны как для простой...
Как правильно расширить и реализовать метод sendEmail из Person черта (интерфейс) внутри Employee...
У меня в одном файле scala следующий класс (и ниже основной метод): class OuterClass { class Inner...
Я изучаю Scala и пытаюсь выяснить, как создать программу MapReduce в Scala, чтобы найти для каждого...
Важное редактирование Проблема решена. Пожалуйста, посмотрите на мой собственный ответ в этом...
Я хочу запустить эту программу. Я новичок в Scala Spark. У меня «ошибка компиляции» кто-нибудь...
Мне нужно разбить строку на массив с элементами в виде двух следующих слов по scala: "Hello,...
У меня есть два массива пар ключей / значений [[String, Int)], к которым я хочу присоединиться, но...
Буду признателен, если вы поможете мне. Во время реализации потоковой передачи искры от kafka к...
Я работаю над клиентской библиотекой для службы REST, которая общается с сервером по протоколу...
У меня есть фрейм данных Spark, как показано ниже - val myDF = Seq( (1,"A",100,0,0), (1...
Как реализовать ConsumerRebalanceListener с использованием Scala? public class...
Есть ли какой-то тип асинхронного функтора у кошек? Или хороший способ подражать такому поведению?...
У меня есть REST API в Scala Spray, который запускает задания Spark следующим образом:...
У меня есть датафрейм с 4 столбцами co1, col2, col3 и col4. Мне нужно: Группировка данных на основе...
Я пытаюсь найти минимальное расстояние между несколькими словами в данном тексте. Предположим, что...
У меня есть датафрейм, как показано ниже - Id,timestamp 100,1 200,2 300,3 400,4 500,5 600,6 А...
Я пытался преобразовать результаты из формы scala (сопоставленной с моделью класса) в json object,...
У меня есть код Scala: import collection.mutable._ def myMethod(mycollection: Map[A, B]) = { ... }...
У меня более 100 миллионов записей, хранящихся в файлах со следующей структурой JSON (реальные...
Я пытаюсь загрузить некоторые файлы в HDFS с использованием Scala. Тем не менее, я получаю ту же...
Для простоты давайте представим, что у меня есть следующий ввод: List(List("A",...
Есть ли способ эффективно разделить пространственное СДР в GeoSpark? например: разделы со многими...
TL; DR Какова наилучшая практика в отношении определения максимальной скорости входящих данных,...