Я использую библиотеку finagle scala в своей базе java-кода. Ниже приведен пример кода из finagle,...
Если я написал макрос Scala, который должен быть применен к объекту или классу Scala, возможно ли...
У меня проблемы с пониманием поведения PDFBox при попытке добавить текст в поток содержимого...
У меня следующая ситуация: у меня есть фрейм данных с «id» и «array» в качестве схемы. Теперь я...
Я хотел бы задать один теоретический вопрос. Представьте, что у нас есть наш главный объект как:...
Платформа: IntelliJ Edition 2018.2.4 (Community Edition) SDK: 1.8.0_144 ОС: Windows 7 Будучи...
Мне нужно добавить пустой столбец StructType в существующий DataFrame. Попробовал следующее: df =...
Я изучаю курс «Удар Apache с помощью Scala - Практические занятия с большими данными» в Udemy. В...
Я новичок в работе с NoSQL базами данных. У меня Spark 1.6.0 на моем кластере, и мне нужно получить...
Я работал над некоторыми scala кодами для запуска потоковой передачи искры для сбора данных kafka....
Я хочу читать вложенные данные из источника тем Kafka, используя Spark Structured Streaming. Мой...
Я пытаюсь вычислить интервал 'n' дней от начальной до конечной даты. В сигнатуре функции в качестве...
у меня есть класс scala с приведенным ниже определением: object EigenvectorCentrality extends...
У меня есть примерный кадр данных следующим образом: val df = Seq((Seq("abc",...
У меня есть функция, которая принимает String* в качестве параметров. Я реализую другую функцию,...
Мне нужна помощь в пересылке параметра предиката в сообщениях Akka. Я создаю предикат, когда...
Я следую наряду с Воспроизведением документации Scala 2.6 и примера кода для создания неблокирующих...
Я новичок в Scala, и я пытаюсь создать среду, которая может читать несколько типов CSV-файлов, и...
В: Как мне записать в Cassanrda только столбцы со значениями из Spark DataFrame и сделать это...
Итак, я работаю над проектом, в котором мы создаем небольшую программу компиляции, но, прежде чем я...
Я написал несколько общих вспомогательных методов в Scala для запросов GET и PATCH с внутренним...
Я использую Zeppelin с Spark (Scala) val sparkLicTextFilePath = "/home/tt/Software/spark-2.3
Мне нужно перебрать кадр данных в определенном порядке и применить некоторую сложную логику для...
У меня есть файл, который содержит такие записи, как, Ввод (необработанная запись журнала): 50.57
Я пытаюсь создать отсортированную коллекцию в состоянии моих групп и получаю ошибку от катализатора...