Допустим, у меня хранятся эти строки JSON в текстовом файле. {"a": "...",...

Итак, у меня есть эта зависимость, которая используется для создания таблиц и взаимодействия с...

Я работаю со Scala для создания нагрузочных тестов через Gatling.Я использую 3 плагина Gradle:...

Этот пример кода не работает должным образом. trait A trait C class X() { object B { def apply(): A...

У меня определен UDF в Scala со значением аргумента по умолчанию, например: package myUDFs import...

Искра внутренне представляет DataFrame как Dataset[Row].Теперь мне нужно набрать:...

Мы пытаемся написать функцию scala udf и вызвать ее из функции карты в pyspark.Схема даты и времени...

пишу кастомную свечу зажигания.В моем методе addBatch я использую ForEachPartitionAsync, который,...

У меня есть искровой фрейм данных с именем flightData2015 в следующем формате:...

При использовании Java / Scala java.sql.Connection я могу добавить некоторую информацию о клиенте...

Я разработал потоковое потоковое воспроизведение (подход с приемником), которое считывает данные из...

У меня есть DataFrame со столбцом title_from, как показано ниже.. Этот столбец содержит предложение...

Я хотел бы получить следующий SQL-запрос: insert into categories values (select max(categoryID)...

Я пытаюсь отправить искровое задание, используя spark-submit, как показано ниже:...

В настоящее время я разрабатываю систему чата, но я столкнулся с проблемой, когда мой список друзей...

Я изучаю документацию Circe и не могу понять, как справиться со следующим. Я бы просто хотел...

Я разрабатываю модель для удаленных хранилищ и в итоге получаю: sealed trait StorageTag case object...

Я пытаюсь оптимизировать работу приложения Spark. Я пытался понять смысл этого вопроса: Как...

У меня есть пакетная работа, разработанная в Scala.Я запускаю задание с помощью сценария оболочки и...

У меня есть проект на Java с Android studio 3.2, и я хочу добавить несколько файлов Scala.Я уже...

Предположим, у нас есть фрейм данных с именем df со столбцом с именем "DATE".Я знаю, что мы можем...

Я использую auto.offset.reset=earliest в своем коде и использовал коммит смещения в kafka с помощью...

Я уже публиковал похожий вопрос, но кто-то дал мне хитрость, чтобы не использовать условие "if"....

У меня есть данные CSV: "id","price" "1","79.07"...

У меня есть вопрос, который меня беспокоит.Списки в Scala являются ковариантными (List[+A])...