Я использую IntelliJ ide и язык scala, я хочу получить доступ к текстовому файлу, хранящемуся в AWS...

У меня есть каталог HDFS с 13,2 ГБ и 4 файлами в нем. Я пытаюсь прочитать все файлы, используя...

Я пытаюсь проанализировать расположение из многораздельной таблицы Hive в Spark с помощью этого...

У меня есть контроллер следующим образом: class MyController @Inject() ( cc : ControllerComponents,...

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

В Scala, если у меня есть функция f (X, Y, Z), можно ли передать переменную W, которая будет...

Как мне получить вывод всех фильмов за каждый год, используя spark.sql? Ouput: (1988,{(Rain Man)...

Я очень новичок в Apache spark и пытаюсь объединить внутреннюю таблицу Book с таблицей, которая...

У меня есть список объектов org.apache.spark.sql.types.DataType, скажем, val tps = [FloatType,...

Я выполняю операции concat и cast внутри запроса SQL Spark следующим образом: spark.sql...

Я читаю данные из файлов паркета, обрабатываю их, а затем сохраняю результат в S3.Проблема...

Я совершенно новичок в программировании на Spark и Scala.В настоящее время я работаю над Spark...

Я пытаюсь отправить файл jar для выполнения на движке искры. Я пытаюсь интегрировать spark с kafka...

В продолжение этого вопроса Мне нужно обработать все результаты, собранные в processResult. Но...

У меня есть топология Kafka Streams, которая содержит AbstractProcessor (фактически два). В одном...

Есть ли лучший способ создать экземпляр StateT[IO, S, A] в объекте Impl? Редактировать: я его...

У меня есть текстовый файл. Теперь я хочу заполнить поле вывода в файле как Exp1 & Exp2. Что я...

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

Я использую Spotify Scio для создания конвейера потока данных Scala, который запускается сообщением...

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

Как определить тип InfiniteFunction, который является функцией и при вызове возвращает другой...

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

Я создал два набора DF, один со списком общих номеров, а другой со списком конкретных номеров. Я...

У меня есть два определения foo, и одно из них более предположительно def foo(f: java.util.function

В этом примере Scala мне нужно остановиться, когда результат StopNow, мне нужно сделать это после...