У меня есть набор данных со следующим форматом более или менее....

Я выполняю запрос ниже в импале, но получаю ошибку, связанную с unix_timestamp AnalysisException:...

Как определить многоуровневый цикл в искре?Для одноуровневого самостоятельного объединения можно...

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

У меня есть JavaPairRDD<Dimension, Metrics>, здесь Dimension и Metrics объекты имеют...

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

Я установил spark и java, но когда я запускаю spark-shell, я получаю эту ошибку: / usr / local /...

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

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

Я работаю над написанием большой таблицы (примерно 1,2b строк) в партике с разделами, я использую...

У меня есть таблица population_table, которая содержит столбцы с user_id, provider_name и city. Я...

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

У меня есть спарк Java-код, который работает хорошо в spark-core_2.11 v2.2.0, но выдает исключение...

Spark 2.4.2 в кластере Amazon EMR (1 мастер, 2 узла) с использованием Python 3.6 Я читаю объекты в...

Задержка планирования увеличивается при получении сообщений из IBM MQ. Привет У меня есть...

Я не смог найти документацию, рассказывающую, как использовать spark-streaming-kafka-0-10_2.10 с...

Я пытаюсь выяснить, как проверить, совпадают ли две таблицы в sql. Таблицы должны быть одинаковыми,...

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

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

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

Я запускаю spark-submit: $SPARK_HOME/bin/spark-submit --class org.apache.spark.graph.algorithms

Я пытаюсь понять метод слияния в искре. У меня есть JavaRDD<String> (который состоит из 16310...

Я пытаюсь запросить несколько таблиц. И мне нужно иметь подзапрос с BETWEEN в качестве оператора....

ТАК Я использую версию сообщества databricks для анализа xml-файла в искровых фреймах с...

Я пытаюсь правильно настроить Spacy для работы с моим кодом Pyspark.Я просто пытаюсь использовать...