Каким будет эквивалентный строковый SQL-запрос для этого же запроса: val streamingWindowDF =...

В упрощенной реализации Actor в RedBook они используют очередь на основе узлов MPSC для Actor. Они...

Почему IntelliJ не может отладить линию println(s"foo: $nr") в коде ниже? Я что-то не так...

Я очень новичок в Scala и пытаюсь разобрать xml-файл, чтобы преобразовать его в csv для дальнейшей...

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

Я создал простой REPL бот для scala. Он работает в среде Linux и обрабатывает записанный scala код...

Когда я запускаю запрос GroupBy в spark-shell, он показывает мне отличные результаты, но когда я...

У меня есть CSV-файл, как показано ниже. PK,key,Value 100,col1,val11 100,col2,val12 100,idx,1 100...

Этот код пока работает отлично, но мне не нравятся кортежи везде, подобные этому, что приводит к...

Я запускаю какой-то тест и получаю небольшой DataFrame с примерно 3-6 столбцами и 10-20 строками.И...

Итак, я пишу логику для извлечения данных из другого файла в формате xml на языке программирования...

Я пытаюсь записать данные в HDFS из структурированного потокового кода в Scala. Но я не могу этого...

В данный момент я работаю над проектом, который кросс-компилируется в Scala.js и обычную JVM Scala

Я использую sc.wholeTextFiles(",".join(fs), minPartitions=200) для загрузки 6k XML-файлов...

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

У меня есть список Either, который представляет ошибку: type ErrorType = List[String] type...

У меня есть приложение, которое выполняет некоторую работу, и в конце оно должно прочитать какой-то...

У меня есть высокоуровневая структура кода, которая выглядит следующим образом: val block: (=>...

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

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

Я использую spark со scala для чтения определенного раздела Hive. Раздел: year, month, day, a и b...

Я начал работать с Akka-GRPC, используя ProtoBuffers, образцы в сети очень чистые и лаконичные, но...

Я пытаюсь запустить толстую банку через spark-submit на EMR. Я столкнулся с проблемой, связанной с...

Мое требование - преобразовать две строки и создать файл JSON (с использованием JSON-спрея) и...

Я новичок в области больших данных. Я пытаюсь прочитать некоторые файлы JSON и сделать анализ, а...