У меня есть 2 n-кортежа, и мне нужно объединить их значения в качестве параметров для функции foo....

Ошибка при подключении SQL Server к Spark Scala. Исключение в потоке "main" java.lang

У меня есть данные в таблице / Dataframe. table/dataframe: temptable/temp_df StoreId,Total_Sales...

Я перебираю карту со значением ключа как Map(fields -> List( pangaea_customer_id, email_hash,...

Я использую kafka 0.10 для получения сообщений в режиме реального времени и использую spark 2.2 в...

Я запускаю запланированное (один раз в день) приложение Spark на AWS EMR, приложение является...

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

У меня есть кадр данных, как показано ниже, val x = Seq(("A", "B",...

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

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

У меня проблема с Spark Shell. Итак, в сеансе оболочки - Я импортировал следующее - import scala

Этот вопрос Простой идиоматический способ определения порядка для простого класса дел выглядит...

Существует ли способ выборки k элементов из коллекции в режиме ошпаривания, чтобы каждый элемент...

Я знаю, что могу получить желаемый результат, используя Array (1,2,3) .mkString (","), но я хочу...

Для этих заданных входных данных; |BASE_CAP_RET|BASE_INC_RET|BASE_TOT_RET|acct_cd|eff_date|id |...

Если у меня есть широкий фрейм данных (200 м столбцов), который содержит только IP-адреса, и я хочу...

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

У меня есть ресурс, который выполняет потенциально длительную операцию блокировки. В реальном коде...

Spark 1.6 с scala я пытаюсь выполнить регулярное выражение в spark sql. В Spark Dataframe один из...

Я новичок здесь. Я работаю с Spark 2.4.4 и Scala. У меня есть СДР с тремя столбцами с первой...

У меня есть фрейм данных:...

Я пытаюсь сравнить две таблицы (), читая как DataFrames. И для каждого общего столбца в этих...

В моем понимании следующие две функции и их вызовы должны быть идентичны: def f1[L1 <: HList,...

Я новичок в драйвере mongo scala. Я пытаюсь добавить размер пула соединений при запуске экземпляра...

У меня есть строка formattedDataInputDateTime, которую я хочу вставить в таблицу в качестве типа...