Я новичок в Apache Spark, пытаюсь запустить SparkContext в Scala API (платформа Play).Когда я...
Я пытаюсь достичь следующего фрейма данных: ------------------------- | FOO | BAR | BAZ | | lorem |...
У меня есть метод с такой подписью: def fn1[A1, P, Q, E, U, C[_]]( fn: A1 => Query[E, U, C],...
Попытка преобразовать исходную строку Apache Flink в карту с помощью scala . Моя потоковая строка...
Я хочу прочитать файл для ex: schema_file , который будет содержать схему и использовать ее в коде...
Я использую Akka HTTP для отправки данных в пост-запросе и накапливаю их в списке.Мне нужно...
Я работаю со структурированным входным файлом, который содержит userId, seqId, eventType и страну
Я читаю большое количество CSV из S3 (все с префиксом ключа) и создаю строго типизированный Dataset
Я бы хотел сделать API класса составного кейса чище.Итак, рассмотрим модифицированную версию...
У меня есть следующий блок кода Scala как часть моего конвейера обработки данных.Насколько я...
Я экспериментирую с сердцебиением при запуске приложения Spark Streaming. Я знаю значение...
У меня есть следующие значения: case class Rating(user_ID: Integer, movie_ID: Integer, rating:...
У меня есть метод, который преобразует набор данных из кадра данных.Метод выглядит так: def...
В основном все утилиты для работы с календарями на неделю настроены на воскресенье / воскресенье...
Я пытаюсь создать черту, которая имеет универсальную функцию, которая возвращает пятно Query и...
Я пишу приложение Spark в Scala, используя Spark Structured Streaming, которое получает некоторые...
В Scala есть библиотеки, которые позволяют вам писать SQL и возвращать неизменные коллекции
Я создал бенчмарк для метода, который с помощью динамического программирования находит самую...
Может кто-нибудь дать мне знать, как получить row_number в наборах данных.Row_number apis приводит...
У меня есть фрейм данных с двумя столбцами, где в каждой строке есть разреженный вектор.Я пытаюсь...
Я хочу добавить столбец прогноза в свой набор данных после того, как я использовал алгоритм Kmeans...
Я боролся с этим зверем в течение нескольких дней и нуждаюсь в некотором руководстве.Мой...
Допустим, у меня есть строковый шаблон, который содержит N заполнителей:...
У меня есть фрейм данных в scala, который является результатом попарного сравнения всех строк в...
Я столкнулся с проблемой, пытаясь преобразовать мой Dataframe в набор данных, чтобы я мог запустить...