У меня есть требование проанализировать файл журнала в директории Linux и использовать информацию в...

Я изучаю Spark и его параллелизм, связанный с распределением разделов RDD.У меня машина с 4...

Вопрос в некотором роде похож на проблему: Измените метку времени в формате UTC в Pyspark По сути,...

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

Давайте предположим, что у меня есть RDD[Foo], где case class Foo(bar: String, baz: Int), и у меня...

Два Writestream для одного и того же приемника базы данных не происходят последовательно в Spark...

Моя команда сейчас вступает в сферу структурированного потокового вещания.Я относительно новичок в...

Я ищу способ построения фрейма данных из файла Excel в spark с использованием scala?Я упомянул ниже...

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

У меня есть такой массив: val a = Array(1,Array(1,2)) хочу получить результат, подобный Array(1,1...

Мне нужно перегрузить === в следующем запросе users.filter(_.id === userId) , чтобы я мог применить...

Например, если у меня есть следующий фрейм данных val tempDF=Seq(("a",2),("b"...

PairRDDFunctions.aggregateByKey скалярные состояния Чтобы избежать выделения памяти, обеим функциям...

Есть ли способ получить Hadoop FileSystem от Spark Executor при выполнении операции mapPartitions...

Я хотел применить сопоставление с шаблоном сразу после yield для получения полного понимания...

Я пытаюсь прочитать json и разобрать два значения valueStr1 и valueStr2 из темы Кафки...

Я обнаружил странное явление: class A { val dual: A = this object T { implicit def doubleDual(t:...

У меня есть программа, которая запускается с помощью инструмента scala sbt.Можно ли запустить эту...

Я пытаюсь прочитать данные из JSON, у которого есть массив, имеющий значения lat, long, что-то...

У меня есть датафрейм, где я хочу обрезать его по последнему появлению значения Good в столбце PDP

Я пытаюсь сопоставить две строки, в которых есть символ «+». val mystring = "test+string"...

Я пытаюсь изучить Scala и столкнулся с некоторыми проблемами при работе со списками.Я сталкиваюсь...

У меня есть следующая проблема. У меня есть следующий список ввода val input:List[Item]=List(FRDVE...

У меня есть мульти-проект, созданный с использованием sbt, и я хотел бы создать исполняемый файл...

У меня есть переменная, объявленная следующим образом: val jobnameSeq = Seq( ("42409245",...