Существует два набора DataFrame, один из которых «Обучающий набор», другой - «Тестовый набор». Что...

Я использую приближение сходства, чтобы найти сходство Жакара между двумя наборами. val dfA =...

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

Как заменить пустые значения в столбце Field1 DataFrame df? Field1 Field2 AA 12 BB Эта команда не...

В книге Кея Хорстмана "Scala для нетерпеливых" есть примечание о методе применения: Иногда нотация...

Я создаю искровое приложение, используя scala-ide. Во время запуска моего класса из затмения файлы...

Я хочу запустить этот проект: Лямбда-Арка-Спарк (разработано в Scala) Я использую Windows 10. Я...

Я делаю проект в Scala, и я борюсь с определенной вещью. Я делаю матрицу DSL, поэтому я перегружаю...

Я пытаюсь создать проект через maven, в котором я могу использовать Scala и Java на обоих языках. И...

У меня возникли проблемы при попытке отфильтровать строки в столбце на основе нескольких условий....

Я пробую разъем spark-neo4j . В примерах этой ссылки я нашел следующую строку: neo

val jsonString = sc.sequenceFile[Long,String](paths).map(x => { x._2 }) Переменная paths...

У меня есть следующий DataFrame df: url user date followers www.test1.com A 2017-01-04 05:46:00 45...

Мой xml-файл выглядит ниже <?xml version="1.0" encoding="UTF-8"?>...

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

Это кажется простой задачей, но я не могу понять, как это сделать с помощью Scala в Spark (не...

У меня есть следующее определение объекта scala: case class RecursiveSettings ( var recursiveFrom:...

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

У меня есть два кадра данных DF1 и DF2 с id в качестве уникального столбца, DF2 может содержать...

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

Фрейм данных...

У меня есть следующий код: - var ArrayStop = new ArrayList[imeistoppage]() val listings =...

Скажите, что ответ JSON, с которым я работаю, имеет следующий формат: [ { "make":...

Ввод List(1,2), List(3,4), List(1000), List(5,6), List(100, 1,3), List(99, 4, 5). Ожидаемый...

Я кодирую ребра графа из файла val graph = GraphLoader.edgeListFile(sc, "comb.txt")...