У меня есть 2 спарк-RDD, первый содержит отображение между некоторыми индексами и идентификаторами,...

У меня есть Breeze DenseMatrix, я нахожу mean на строку и mean квадратов на строку и помещаю их в...

Я пытался собрать несколько полей в наборе данных и преобразовать их в формат массива json. Я...

Я пытаюсь вычислить де Колмогорова Тест Смирнова в SCALA с распределением [6,6], предполагая, что в...

Я выполняю скользкий запрос и успешно получаю результат с помощью этого вспомогательного метода:...

Я начинающий программист из Python / Java, который пытается разобраться с функциональным...

Я пытаюсь сделать классификацию изображений. Я использую Scala, систему актеров Akka и...

У меня есть датафрейм: +---+---+----+ | id|key|name| +---+---+----+ | 10| 1| a| | 11| 1| b| | 12|...

У меня есть данные, которые не помещаются в памяти. Итак, я читал по следующим ссылкам:...

Я работаю над книгой «Функциональное программирование в Scala», и в конце главы о структурах данных...

В общем, можете ли вы объявить val в scala перед присвоением ему значения? Если нет, то почему нет?...

Я пишу собственный потоковый источник Spark. Я хочу поддержать сокращение столбцов. Я не могу...

У меня есть вход spark-dataframe с именем df как +---------------+---+---+---+-----------+...

Я уже написал код в Spark RDD вроде: val result = data.map(x => { val eachrecord = x

Я столкнулся с неожиданным поведением в конечной точке POST-запроса akka-http, который отправляет...

Мне нужно перераспределить геоданные по квадке. Прежде всего, все данные довольно сбалансированы,...

Я видел несколько вопросов о записи одного файла в hdf, кажется, достаточно использовать...

В нашем приложении есть маршруты для потоковой передачи документов JSON. Вот пример: /** GET...

У меня есть ввод spark-dataframe с именем df как,...

Мне нужно конвертировать из любого в базовые числовые типы, такие как Int или Double Я реализовал...

Входной кадр данных: val ds = Seq((1,34.44), (2,76.788), (3,54.822)).toDF("id"...

Может кто-нибудь проверить мой код? Я не знаю, что случилось, но я получил Uncaught SyntaxError:...

Я хочу перенаправить на сайт "www.xxx.com", когда доступ к localhost: 9000. среда - это scala и...

Я пытаюсь настроить свою модель xgBoost на Spark, используя Scala. Моя сетка параметров XGb...

У меня есть вложенное поле, как показано ниже. Я хочу вызвать flatmap (я думаю), чтобы получить...