У меня есть демо в качестве объекта модели Scala. и извлечение данных из кассандры и сохранение в...
Я хочу подтвердить адрес в моих данных, формат проверки Проспект Блок-Б 123. то есть символ числа с...
Мне нужно перебрать все столбцы, чтобы найти сходство значения 1 столбца.Например: ID,FN,LN,Phone...
Задача состоит в том, чтобы найти циклы определенного размера k, где k - пользовательский ввод,...
Я пытаюсь создать фрейм данных из RDD, чтобы иметь возможность записи в json со следующим форматом...
Я хочу зациклить n раз, где n является аккумулятором по одному и тому же rdd скажем, n = 10,...
В последние часы я пытался преобразовать файл JSON в Scala case class с помощью Apache Spark. JSON...
Я получаю исходный файл .txt фиксированной ширины, из которого мне нужно извлечь столбцы размером...
Что такое кластер Spark, эквивалентный локальному [N] автономному.Я имею в виду, значение, которое...
Нужна помощь в написании программы в Spark для преобразования столбцов в строки? Текстовый файл:...
У меня есть класс ctakes, который работал нормально в версии spark 2.3.1 и версии 2.11.8 scala.но...
Я использую intellij, чтобы написать искровой код. И я хочу получить доступ к файлам, хранящимся в...
Итак, у меня есть функция, которая проверяет тип файла, я проверяю файл по сигнатурам, но для...
API = ml.dmlc.xgboost4j.scala.spark.XGBoostClassifier val xgbParam = Map ("eta" -> 0.1f,...
Я создал модели ML и сохранил их в MariaDB как сериализованный объект с Kyro и Spark в App1 .А...
Я получаю поток данных в форме: +--+---------+---+----+ |id|timestamp|val|xxx |...
Я использую spark и scala, выбираю данные из таблицы с именем persons из улья, в таблице есть...
Я новичок в распространении MapR. Мне нужны операции чтения и записи в БД MapR с использованием...
У меня есть этот XML-файл, расположенный в S3, который мне нужно было бы загружать в...
У меня есть проблема со Spark Scala, которую я хочу умножить в элементах Tuple при потоковой...
Я пытаюсь написать Spark Dataframe в HBase и следил за несколькими другими блогами, и один из них -...
Я обучил модель xgboost в Spark Scala следующим образом: val xgbParamGrid = new ParamGridBuilder()
Вот код, который использует Spark ML для поиска кластеров: val dfRaw = spark.read
Попытка объединить два кадра данных A и B. B выполняет отдельную операцию непосредственно перед...
Не могу найти хорошего ответа, как легко рассчитать смещение часового пояса для данного момента...