Sessione uma coluna de números em grupos de 30 assim que um limite for atingido no Teradata

Considere uma coluna que representa "tempo entre eventos": (5, 40, 3, 6, 0, 9, 0, 4, 5, 18, 2, 4, 3, 2) Gostaria de agrupá-los em baldes de 30, mas baldes que são redefinidos. Resultado desejado: (0, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2, 2, 2, ...

Como agregar janela de tempo de rolagem com grupos no Spark

Tenho alguns dados que quero agrupar por uma determinada coluna e agregar uma série de campos com base em uma janela de tempo de rolagem do grupo. Aqui estão alguns dados de exemplo: df = spark.createDataFrame([Row(date='2016-01-01', ...

Spark - Janela com recursão? - Propagar valores condicionalmente pelas linhas

Eu tenho o seguinte quadro de dados mostrando a receita das compras. +-------+--------+-------+ |user_id|visit_id|revenue| +-------+--------+-------+ | 1| 1| 0| | 1| 2| 0| | 1| 3| 0| | 1| 4| 100| | 1| 5| 0| | 1| 6| 0| | 1| 7| 200| | 1| 8| 0| | ...

Django filtrando em funções de janela

Eu tenho dois modelos no Django, A e B. Cada A tem vários Bs atribuídos, e os Bs são ordenados, o que é feito com o campo B.order_index que conta a partir de zero para qualquer A. Quero escrever uma consulta que verifique se existe algum A onde ...

Função definida pelo usuário a ser aplicada à janela no PySpark?

Estou tentando aplicar uma função definida pelo usuário para Window no PySpark. Eu li que o UDAF pode ser o caminho a seguir, mas não consegui encontrar nada concreto. Para dar um exemplo (extraído daqui:Blog de tecnologia de ...

Funções da janela: PARTITION BY uma coluna após ORDER BY another

Aviso Legal:O problema mostrado é muito mais geral do que eu esperava primeiro. O exemplo abaixo é retirado de uma solução para outra pergunta. Mas agora eu estava usando esta amostra para resolver muitos problemas mais - ...

SQL Server 2014 Mesclando intervalos de datas sobrepostos

Tenho uma tabela com 200.000 linhas em um banco de dados SQL Server 2014 assim: CREATE TABLE DateRanges ( Contract VARCHAR(8), Sector VARCHAR(8), StartDate DATE, EndDate DATE ); INSERT INTO DateRanges (Contract, Sector, StartDate, Enddate) ...

unção da janela @Postgres e agrupar por exceção

Estou tentando montar uma consulta que recuperará as estatísticas de um usuário (lucro / perda) como resultado cumulativo, por um período de tempo. Aqui está a consulta que tenho até agora: SELECT p.name, e.date, sum(sp.payout) OVER (ORDER BY ...

GRUPO POR Datas consecutivas delimitadas por lacunas

Suponha que você tenha (no Postgres 9.1) uma tabela como esta:

Agregue valores em um intervalo de horas, a cada hora