Resultados da pesquisa a pedido "window-functions"
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 ...
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, ...
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 ...
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 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 ...
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çõ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 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 ...
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 ...
Spark e SparkSQL: Como imitar a função de janela?
DescriçãoDado um quadro de dadosdf id | date --------------- 1 | 2015-09-01 2 | 2015-09-01 1 | 2015-09-03 1 | 2015-09-04 2 | 2015-09-04Eu quero criar um contador ou índice em execução, agrupados pelo mesmo id eclassificados por data nesse ...