Я работаю в контексте макроса Scala 2.12. Все поля конструктора обнаруживаются динамически, нет...

Я новичок в SO, но потратил дни на изучение вопросов.Ближайший связанный с этим вопрос, который я...

У меня есть класс с некоторыми значениями Option, и мне нужно применить все значения, которые в...

Как в scala можно преобразовать akka.util.ByteString в java.io.InputStream? Я пробовал следующее:...

Во время агрегации по группам в настоящее время я принимаю первое значение.Но мне нужно первое...

В моем искровом коде есть RDD[Person], и я хочу преобразовать этот rdd в dataframe.Класс Person не...

Я получил исключение при попытке чтения из набора данных SparkSql с помощью разъема cosmosdb в...

Я пытаюсь загрузить данные CSV в таблицу Hive, используя SparkSession.Я хочу пропустить данные...

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

Я хотел бы импортировать таблицу из Oracle в Hive.Эта таблица содержит поле с меткой времени типа...

Я нахожусь в процессе реализации простого в памяти Redis-подобного хранилища KeyValue и испытываю...

У меня есть задание Spark Streaming, которое при запуске запрашивает Hive и создает объект Map [Int...

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

У меня есть проект Gradle со следующей структурой папок. project ├── build.gradle └── src ├── main...

Как загрузить CSV-файл У меня есть два пользователя CSV-файла и твиты. Где в таблице твитов я...

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

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

Я определил неявный класс, предоставляющий метод foo для всех экземпляров Double.Странно, но этот...

Я хочу прочитать N последних версий объекта S3 и поместить их все в структуру Map [version,...

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

Я имел в виду ответ, опубликованный в Неявное преобразование Scala для объекта sealed trait Command...

Пожалуйста, вы можете мне помочь?У меня есть набор данных из 80 файлов CSV и кластер из одного...

У меня есть СДР ниже: Array( (0, "xx"), (1, "xx"), (2, "xx"), (1,...

Я пытаюсь выполнить какое-то модульное тестирование в приложении Spark Streaming, которое включает...

Я хочу иметь функцию для динамического выбора столбцов искровых Dataframe по их типу данных. До сих...