Я пытаюсь найти класс case, соответствующий каждой строке моего файла json. У меня как ошибка:...
Моя проблема в этом.У меня есть пользовательский фрейм данных, созданный из записей netflow,...
1. Потоковые данные поступают из Кафки 2.Потребление через потоковую передачу с использованием...
Очень простой вопрос Невозможно загрузить внешний ресурс javascript на сервер. Я работаю над...
Вот как я могу проверить, является ли число четным / нечетным в Ruby: def even_or_odd(number)...
Я пытаюсь скопировать массив универсального типа, используя карты. class MaObj[T](val arr :...
Я использую 2.4.0 Spark-core и Spark-sql. Я пытаюсь создать sparkSession, затем создать диапазон и...
У меня есть приложение Flink, которое использует FlinkKafkaConsumer. Я заинтересован в получении...
В Scala, учитывая двоичный файл, я заинтересован в получении списка элементов Array [Byte]....
Я новичок в Spark, и мне было интересно, возможно ли следующее: У меня есть 2 Datasets, и у них...
У меня есть функция, которая делает вызов API для внешнего API Допустим, функция выполняет нечто...
Я получаю ошибку аутентификации JSch, когда мой пароль содержит символы типа *,!. Могу ли я узнать,...
Я использую spark 2.3.0 и hadoop 2.9.1 Я пытаюсь загрузить файл CSV, расположенный в hdfs, с...
Я пытаюсь записать правила в модель вот что у меня есть trait Criterion[T] { val name: String def...
Я пытаюсь понять асинхронные вычисления на cats.effect.IO примерах и получил некоторое...
Я пытаюсь создать класс case, чтобы иметь возможность отображать каждую строку моего файла JSON,...
Вот мой код, который я написал в Scala package normalisation import org.apache.spark.SparkContext...
Когда я пытаюсь запустить тот же код в режиме клиента, код выполняется успешно.Но при запуске в...
Я экспериментирую с fs2.Stream одновременными функциями и получил некоторое недопонимание о том,...
У меня есть датафрейм, который состоит из двух столбцов, одного Int и другого Строка:...
Я хотел бы объявить @transient lazy val в качестве параметра конструктора.Пример: class...
Пожалуйста, мне нужна ваша помощь, я пытаюсь отправить внешний файл конфигурации для моего...
Я пытаюсь провести юнит-тестирование одним из моих методов.Внутри этого метода есть строка: val...
Я пытаюсь вставить один фрейм данных в другой. scala> addressOrigRenamed.show...
Я работаю с моделью ALS Apache Spark, а метод рекомендуемаяForAllUsers возвращает фрейм данных со...