Я получаю JSON. Я не знаю, на каких клавишах появится проблема. Когда spark видит разные типы для...
Я новичок в Spark Graphx, есть ли способ поиска соседей по списку vertexId из res? кроме итерации с...
Я пытаюсь создать SparkConsumer, чтобы в этом случае я мог отправлять сообщения в формате csv на...
Я создаю таблицу феникса со структурой ниже CREATE TABLE IF NOT EXISTS "TEST1"(...
val config = new ClientConfig() val feature = HttpAuthenticationFeature.basic("ab",...
В Spark можно получить первое ненулевое значение после текущего вхождения для столбца в окне: val...
Я новичок в искре. У меня есть датафрейм, как показано ниже. Это пример кадра данных, ID имеет 32...
У меня есть данные JSON, поступающие через API. У меня есть набор политик, которые мне нужны для...
Я пытаюсь запустить приложение, созданное с помощью потоковой структурированной искры - ввод данных...
Я смотрю на этот набор данных по аренде дронов. Я хотел бы попробовать сгруппировать по столбцу...
Как мне сравнить эти две строки: val a = "fit bit versa" val b = "fitbit"...
Я работаю над упражнением, которое требует от меня реализации isPrime в scala с использованием...
У меня есть набор координат (x, y) в качестве моих данных в CSV-файле. Я хочу передать эти x и y в...
Мне нужно сравнить два кадра данных в моем искровом приложении. Я прошел следующий пост. Как...
Когда я пытаюсь прочитать данные в файле, используя spark 2.2.1, я получаю следующее исключение...
Я с тестами Гатлинга в Scala и хочу проверить некоторые поля в декодированном токене JWT. Я знаю,...
Я реализовал простые потоки в Scala с реализацией потока Project Reactor. val iterators:...
var columnnames = "callStart_t, callend_t" // Имена столбцов временной метки являются динамическим...
Наше требование - тайм-аут сеанса через определенный промежуток времени, и пользователю необходимо...
Я получаю следующую ошибку времени компиляции здесь: def fun1(item: TextMapWritable, field:String,...
Программа My Spark Streaming получила следующую ошибку: Исключение в потоке "main" java.lang
У меня есть код, написанный полностью на scala, который использует потоковую передачу по искру для...
Я пытаюсь получить значение для функции lowerByKey ниже на RDD, однако это не дает правильный...
Я присоединяюсь к двум фреймам данных примерно так: val joinCols = Array ("first_name",...
Я использую Spark 2.4.0 и Scala 2.11. У меня есть набор данных [Users], когда Users состоит из:...