Упорядоченное количество последовательных повторов / дубликатов

Я сильно сомневаюсьЯ делаю это наиболее эффективным способом, поэтому я отметил

Перескочить пробел в SQL через конкретное условие и правильное использование lead ()

Функция окна Postgres и группа исключений

Я пытаюсь собрать запрос, который будет извлекать статистику пользователя (прибыль / убыток) в виде совокупного результата за определенный период времени. Вот запрос, который я имею до сих пор: SELECT p.name, e.date, sum(sp.payout) OVER (ORDER ...

Для функций Spark Window требуется HiveContext?

Я пробовал один пример оконной функции на искре из этого блогаhttp://xinhstechblog.blogspot.in/2016/04/spark-window-functions-for-dataframes.html.Получение с...

Результат:

от ответственности:Показанная проблема гораздо более общая, чем я ожидал. Пример ниже взят из решения другого вопроса. Но теперь я взял этот образец для решения многих проблем, в основном связанных с временными рядами (посмотрите на раздел ...

Задача Spark не сериализуется с помощью функции задержки окна

Я заметил, что после того, как я использую функцию Window над DataFrame, если я вызываю map () с функцией, Spark возвращает исключение «Задача не сериализуем...

Учитывая вышеизложенное, запрос будет следующим

приведен пример того, чего я пытаюсь достичь в базе данных Redshift. У меня есть переменнаяcurrent_value и я хочу создать новый столбецvalue_desired это: такой же какcurrent_value если предыдущая строка равна нулюравно ...

Как фильтровать данные с помощью оконных функций в спарк

У меня есть следующие данные:

Привет спасибо. Моя проблема: зачем столбцам lv_asc и lv_desc давать одинаковый результат? Для lv_desc я ожидаю порядка 140, 120, 100, 500, 800, 900, потому что окно упорядочено наоборот.

Оконная функция PostgreSQL: разделение по сравнению

Я пытаюсь найти способ сделать сравнение с текущей строкой в ​​предложении PARTITION BY в функции WINDOW в запросе PostgreSQL.Представьте, что у меня есть ко...