Запрос не выполняется с коррелированным подзапросом.Выдает ошибку «столбец внешнего запроса не...
ОБНОВЛЕНИЕ Ссылка SQL FIDDLE https://www.db -fiddle.com / f / 9t63on5kYWUNrHqXkThb1P / 4 Вывод...
Я получаю сообщение об ошибке при выполнении кода: Ошибка: AttributeError: объект 'SQLContext' не...
Я хочу переставить несколько столбцов в таблице Spark SQL Я нашел это решение только для двух...
Я пытаюсь реализовать типизированный UDAF, который возвращает сложный тип.Каким-то образом Spark не...
У меня есть 2 входных файла (один в JSON, а другой в паркетном), я пытаюсь объединить эти 2 больших...
Я знаю, как передать структуру с внутренней структурой в UDAF из этого - Передать структуру в UDAF...
У меня есть следующая схема - root |-- id:string (nullable = false) |-- age: long (nullable = true)...
моя работа с искрой; val df = spark.sql(s"""""") df.write
У меня есть набор данных со столбцом, который имеет данные в виде дд / мм / гггг. Теперь, используя...
Я должен оглядываться каждые три месяца и добавлять сумму за предыдущий месяц, используя колонку....
У меня есть значения в фрейме данных, и я создал структуру таблицы в Teradata.Мое требование -...
У меня возникла проблема при создании spark-tensorflow-connector на Dataproc в GCP. Проблема...
Мне нужно, чтобы все покупатели вошли в ЛЮБОЙ из 20 лучших магазинов по объему продаж ($).Я также...
Я хочу преобразовать запрос HiveQL с оконной функцией в запрос Scala Spark ... но я постоянно...
У меня есть разделенный фрейм данных, сохраненный в hdfs. Я должен периодически загружать новые...
Итак, мне действительно нужна помощь с глупостью, но, видимо, я не могу справиться с этим сам. У...
Если значения объединения accomm_bk и type_bk равны нулю, то как искать значения в таблицах, скажем...
Я работаю над отчетом об атрибуции и кэширую фрейм данных, так как он часто используется на более...
Для локального тестирования запросов мы можем иметь встроенный экземпляр красного смещения,...
Я знаю, что в scala существует способ, как упомянуто ниже. val joined_df = df1.join(broadcast(df2),...
Я использую sparkSQL, у меня есть один столбец, общее количество которых составляет 1252226. spark
Скажем, у меня есть некоторые данные подписки, которые выглядят следующим образом: user_id...
У меня есть фрейм данных pyspark со следующими данными: | y | date | amount| id |...
У нас есть хранилище BLOB-объектов, куда в течение дня поступает множество файлов.У меня есть...