Привет, у меня есть вопрос относительно проверки списка в Scala. У меня есть метод, который...

У меня есть этот rdd, содержащий кортежи, и сбор их даст мне список. [x1, x2, x3, x4, x5] Но я хочу...

Я хотел бы разделить мой RDD относительно запятых и получить доступ к предопределенному набору...

Я работаю над модулем API в Scala, который запрашивает базу данных и возвращает извлеченные данные...

Я пытаюсь определить способ фильтрации элементов из WrappedArrays в DF. Фильтр основан на внешнем...

Как использовать метод Spark hadoopFile, чтобы использовать пользовательский формат ввода с типом...

Когда я пытаюсь создать фрейм данных со схемой в приведенном ниже коде, он не работает, и если это...

Как создать несколько фреймов данных, используя один и тот же класс case?Предположим, я хочу...

У меня большой набор данных для преобразования одной структуры в другую. Во время этой фазы я также...

У меня есть ноутбук, основанный преимущественно на Python, и теперь я хочу интегрировать некоторые...

Когда вы используете scala repl, простой вызов System.loadLibrary ("opencv_410") (в случае, если вы...

Я следовал этому примеру для вычисления TFIDF каждого слова в моих документах.Однако мой...

Каждый день я получаю файл с ~ 2k столбцами.Есть 900 столбцов "отношения".Например: data.id | name...

здесь - изображение CSV-файла. val df = Seq((0l, "East", "100", " "),...

Моя текущая проблема следующая ... Exception in thread "main" org.apache.spark.sql

У меня есть dataframe с 5 столбцами. Мне нужно динамически проверять столбцы на наличие нулевых...

В приложении Scala, развернутом через Spark, у меня есть строка кода, которая вызывает функцию Java...

У меня есть определенный сценарий создания извлечения файла dat/delimited в scala/spark; просто...

Мне трудно понять, почему я не могу использовать составную функцию и написать новую.Например: у...

Я недавно использовал фреймворк LMAX Disruptor. Как узнать количество задач, которые не были...

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

У меня есть таблица в dataframe с тремя столбцами.city_name, driver_name, транспортные средства, из...

Я пытался преобразовать старую версию теста потоковой передачи Yahoo для Flink в новую версию,...

У меня есть 3 следующих класса дел: case class Profile(name: String, age: Int, bankInfoData:...

Я использую внешний проект maven, в котором сгенерированный jar содержит двоичный файл foo/bar/file