Я использую com.datastax.spark:spark-cassandra-connector_2.11:2.4.0, когда запускаю ноутбуки...

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

Мне нужно провести модульное тестирование одного метода, вход которого - DStream[String].Поэтому я...

Я пытаюсь обновить версию Spark с 1.6.2 до 2.3.0.В настоящее время я использую Scala версии 2.10,...

Я недавно узнал об инструментах веб-RAD.Из этих платформ CUBA и Wavemaker кажутся мне наиболее...

просто выполнение этого запроса spark-sql в блоках данных работает нормально: %sql select...

У меня есть несколько Map[String, String] в List (Scala).Например: map1 = Map("EMP_NAME"...

Я хочу разделить столбец "_time", который содержит дату и время (как fieldtype = string) даты...

Я пытаюсь транслировать данные из темы kafka avro. Ниже приведен мой фрагмент кода: val...

Я планирую использовать Bifunctor IO с каналом для ошибок.Поэтому я попытался предоставить неявный...

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

Я использовал MinHashLSH с приблизительным значением сходства со Scala и Spark 2.4, чтобы найти...

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

Я пытаюсь использовать symulacrum @typeclass, чтобы не писать шаблон Ops / Syntax.У меня есть черта...

Мы планируем интегрировать бизнес WhatsApp для нашего приложения, где мы сможем использовать его...

Я пытаюсь заменить символ "/" пробелом ("") из данных в столбце с именем UserAgent в кадре данных...

У меня есть фильмы и соответствующие им касты в базе данных Neo4j, и я хочу создать COWORKER...

Я пытаюсь проанализировать следующий Json с json4s в Scala, но не могу из-за вложенной структуры: [...

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

Я использую Kryo для десериализации класса, первоначально сериализованного в Spark.Kryo записывает...

Мой текущий код многократно создает новые фреймы данных (df_1, df_2, df_3) с использованием одной и...

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

У меня есть столбец даты "a", который нужно сравнить с двумя другими столбцами "b" и "c" типа date

Я пишу сервер, который должен анализировать строки JSON, загруженные клиентами.В настоящее время я...

это моя схема данных: `root |-- customerid: string (nullable = true) |-- event: string (nullable =...