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

Я пытаюсь создать сеанс Spark в модульном тесте, используя приведенный ниже код val spark =...

Динамическое присоединение к фреймам данных с использованием Spark Scala, когда столбцы JOIN...

У меня есть таблица в одной среде, которая актуальна для каждого раздела с каналом данных на aws....

Я пытаюсь реализовать функцию, которая с учетом DynamoDB и именем таблицы, которую я знаю,...

У меня есть пример дела: val df = ... // read from HDFS / file / ... println(df.count) val newDf =...

Я хотел бы сделать несколько модульных тестов для функции внутри моего класса, упрощенный пример:...

Моя цель - выполнить несколько запросов к базе данных с асинхронного контроллера, а затем вернуть...

У меня есть небольшая библиотека Scala, которую я хочу использовать в приложении Scala.js:...

У меня есть список всех активных заданий, в заявке на работу с искрой. sc.statusTracker

Я новичок в Play Framework и мне нужен совет. В моем проекте я отправляю запрос AJAX, но, к...

Я пробовал библиотеку pygmalios / реактивныйinflux-spark , но ее зависимость подвержена ошибкам с...

Ниже мой фрейм данных: val myDF= spark.sql("select company, comp_id from my_db.my_table")...

Я новичок в функциональной парадигме программирования и Scala. Я пытаюсь решить проблему с помощью...

У меня есть базовая операция - отфильтровать фрейм данных / rdd. val sc = ... val seqRDD = sc

Я пытаюсь включить эту искру. Датафрейм: ID STATUS COUNT a 1 3 a 2 2 b 2 4 c 3 5 d 1 3 d 2 3 В это:...

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

def fromRdd[ K: GetComponent[?, ProjectedExtent]: (? => TilerKeyMethods[K, K2]), V <: CellGrid...

Я пытаюсь проверить столбец фрейма данных scala по регулярному выражению, используя udf с...

Я новичок в Spark. Я написал несколько кодов в scala и выполнил в spark-shell. Однако я хочу, чтобы...

val spark = SparkSession.builder().appName("Test").master("local").getOrCreate()...

У меня есть набор данных, как показано ниже Dataset<Row> dataset = ... dataset.show() | NAME...

Я проверял функцию искрового окна, чтобы проверять попадание страницы в 30 секунд, но он продолжал...

Из java.util.List [CustomObject] Я хочу удалить значение и создать строку, разделенную запятыми,...

Мне нужно получить все имена файлов по определенному пути (имя корзины / лендзона / имя таблицы) в...