Resultados da pesquisa a pedido "window-functions"
SparkSQL - Função Lag?
Eu vejo nissoPostagem do DataBricks [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] , há suporte para funções de janela no SparkSql, em particular, estou tentando usar a função de janela lag (). Eu tenho ...
Função de tabela de referência cruzada no Postgres retornando uma saída de uma linha quando espero várias linhas
Atualmente tenho uma mesam do seguinte formato: id scenario period ct 2 1 1 1 2 1 2 1 2 1 3 1 2 1 4 1 2 2 1 1 2 2 2 1 2 2 3 1 2 2 4 1 2 3 1 1 2 3 2 1 2 3 3 1 2 3 4 1Eu quero criar a seguinte tabela: id scenario period 1 2 3 4 2 1 1 1 2 1 2 1 2 ...
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 - ...
Funções da janela Spark - intervalo entre datas
Estou tendo um Spark SQLDataFrame com dados e o que estou tentando obter são todas as linhas que precedem a linha atual em um determinado período. Então, por exemplo, eu quero ter todas as linhas de 7 dias antes da linha especificada. Eu descobri ...
Função Oracle Lag com parâmetro dinâmico
Eu tenho um problema específico. Eu tenho uma tabela que contém valores inválidos. Preciso substituir os valores inválidos (aqui0) com o valor anterior maior que0. A dificuldade é que não é apropriado usar uma atualização ou uma inserção ...
Função Apache Spark Window com coluna aninhada
Não tenho certeza se isso é um bug (ou apenas sintaxe incorreta). Eu procurei e não vi isso mencionado em outro lugar, então estou perguntando aqui antes de registrar um relatório de bug. Estou tentando usar uma função de janela particionada em ...
Executando total sobre o grupo de repetição por itens com base no tempo no Oracle SQL
Meu primeiro post, então tenha paciência comigo. Eu quero somar com base em um valor que é dividido por datas, mas quero apenas a soma para as datas, não para o grupo por item no total. Estão trabalhando nisso há dias, tentando evitar o uso de um ...
função windowing first_value no pyspark
Estou usando o pyspark 1.5, obtendo meus dados das tabelas do Hive e tentando usar as funções de janelas. De acordo comesta [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] existe uma função analítica ...
Como "redefinir" a execução do SUM após atingir um limite?
Eu escrevi uma consulta que cria duas colunas:the_day, e asamount_raised naquele dia. Aqui está o que eu tenho: [/imgs/SlNQH.png] E eu gostaria de adicionar uma coluna que tenha uma soma contínua deamount_raised: [/imgs/EKrQf.png] Por fim, ...
Usando funções de janelas no Spark
Estou tentando usar rowNumber nos quadros de dados do Spark. Minhas consultas estão funcionando conforme o esperado no shell Spark. Mas quando eu escrevê-los no eclipse e compilar um jar, estou enfrentando um erro 16/03/23 05:52:43 ERROR ...