Мне потребовалась помощь в использовании функции Spark ASCII (строковая функция sparkSQl) с...

Следующее изображение предназначено для объединения spark sql. Одна из задач случайной записи...

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

Раньше мы использовали Spark 2.3, сейчас мы находимся на 2.4: Spark version 2.4.0 Using Scala...

Я новичок в программировании Scala, и в настоящее время я работаю с RDD.Я пытаюсь передать RDD в...

Привет! Я использую spark Mllib и выполняю приближение сходства между набором данных 1M и набором...

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

Я хочу разбить дату вместо моего времени в моем Spark Dataframe, как я могу это сделать?...

Я использую Ambari с HDP-2.6.0.3, где у меня установлена ​​искра. Когда я проверяю версию spark...

У меня есть куча сообщений в kafka, и я использую потоковую обработку для обработки этих сообщений....

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

Следующее: val pivotDF = df.groupBy("Product").pivot("Country")

У меня много паркетных файлов на S3 (Размеры файлов варьируются от 100 МБ до 400 МБ) Цель состоит в...

У меня есть коллекция массивов scala. Мне нужно получить доступ к значениям в этой коллекции из...

Я пытаюсь обратить вспять (сгладить) группировку, созданную на СДР в Scala, например:...

У меня есть эта таблица ниже: FrameForm | Sections | Framefrom_section | FrameFrom_echelon...

Я сталкиваюсь с проблемой при смешивании функций python map и lambda в среде Spark. Учитывая df1,...

У меня есть указатель диапазона дат внутри zeppelin %pyspark интерпретатор, как показано ниже:...

Я хочу запустить тест tpc-h с искрой на вершине пряжи, я могу генерировать данные, но не используя...

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

Я пытаюсь преобразовать столбец типа String со строкой отметки времени в формате "yyyy-MM-dd...

По умолчанию способ получения spark shell для загрузки дистрибутива с сайта .Тем не менее, эта...

Я отправил образец spark (задание предоставлено в коде Spark) в кластер k8s из-за java.net

Я пытаюсь сохранять DataSet в индекс ElasticSearch каждый день (расписание с Oozie), но у меня...

У меня есть сценарий использования, в котором я должен подписаться на несколько тем в kafka в...