отставание оконной функции spark sql

Я смотрю на функцию слайда окна для Spark DataFrame в Spark SQL, Scala.У меня есть датафрейм с колонками Col1, Col1, Col1, date.

большое спасибо! Я попробую! :)

я есть такая таблица:

 в

 группа. На самом деле, это соответствует рангу, а не номеру строки, но, возможно, это приемлемо для вас.

ющий выбор Oracle SQL позволяет мне выбрать все строки таблицы, которыедублируется в соответствии с некоторыми полями, например, они имеют одинаковыеCOLUMN_1, COLUMN_2 а такжеCOLUMN_3 SELECT * FROM ( SELECT t.*, ROW_NUMBER() OVER (PARTITION BY ...

Хорошо, спасибо за ваши усилия. Похоже, какой-то подзапрос неизбежен ...

о, изначально это была просто шутка с моим другом, но это превратилось в интересный технический вопрос :) У меня есть следующееstuff Таблица: CREATE TABLE stuff ( id serial PRIMARY KEY, volume integer NOT NULL DEFAULT 0, priority smallint NOT ...

Нет, он не дает результатов, указанных OP

жен применить определенное преобразованиеfn(argument), Вотargument равноvalue, но не тогда, когда это отрицательно. Когда вы получаете первый отрицательныйvalue, затем вы «ждете», пока он не суммирует последовательные значения, и эта сумма ...

Эквивалент PostgreSQL для TOP n WITH TIES: LIMIT «со связями»?

Я ищу что-то подобное в SQL Server: SELECT TOP n WITH TIES FROM tablenameЯ знаю оLIMIT в PostgreSQL, но существует ли эквивалент вышеупомянутого? Мне просто любопытно, так как каждый раз для меня будет сохраняться дополнительный запрос. Если у ...

GROUP BY последовательные даты, разделенные пробелами

Предположим, у вас есть (в Postgres 9.1) таблица, подобная этой: date | valueкоторые имеют некоторые пробелы (я имею в виду: не каждая возможная дата между min (date) и max (date) имеет свою строку). Моя проблема заключается в том, как ...

Выберите случайную строку для каждой группы

У меня есть такой стол ID ATTRIBUTE 1 A 1 A 1 B 1 C 2 B 2 C 2 C 3 A 3 B 3 CЯ хотел бы выбратьтолько один случайный атрибут для каждого идентификатора. Поэтому результат может выглядеть следующим образом (хотя это только один из многих ...

Функции окна или общие табличные выражения: подсчитывать предыдущие строки в пределах диапазона

Я хотел бы использовать оконную функцию, чтобы определить для каждой строки общее количество предыдущих записей, соответствующих определенным критериям. Конкретный пример: clone=# \d test Table "pg_temp_2.test" Column | Type | ...