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 ...
Pyspark: função de janela personalizada
Atualmente, estou tentando extrair séries de ocorrências consecutivas em um quadro de dados PySpark e ordená-las / classificá-las conforme mostrado abaixo (por conveniência, solicitei o quadro de dados inicial poruser_id etimestamp): df_ini ...
função da janela spark sql lag
Eu estou olhando para a função de slide da janela para um Spark DataFrame no Spark SQL, Scala. Eu tenho um dataframe com colunas Col1, Col1, Col1, data. Col1 Col2 Col3 date volume new_col 201601 100.5 201602 120.6 100.5 201603 450.2 120.6 ...
Função condicional de avanço / atraso do PostgreSQL?
Eu tenho uma tabela como esta: Name activity time user1 A1 12:00 user1 E3 12:01 user1 A2 12:02 user2 A1 10:05 user2 A2 10:06 user2 A3 10:07 user2 M6 10:07 user2 B1 10:08 user3 A1 14:15 user3 B2 14:20 user3 D1 14:25 user3 D2 14:30Agora, preciso ...
Função da janela Spark SQL com condição complexa
Provavelmente é mais fácil explicar através do exemplo. Suponha que eu tenha um DataFrame de logins de usuário em um site, por exemplo: scala> df.show(5) +----------------+----------+ | user_name|login_date| +----------------+----------+ ...
pyspark: contagem distinta em uma janela
Eu apenas tentei fazer um countDistinct em uma janela e recebi este erro: AnalysisException: u'Distinct window functions are not supported: count(distinct color#1926)Existe uma maneira de fazer uma contagem distinta em uma janela ...
Funções de janela no SQLite3
A seleção Oracle SQL a seguir me permite selecionar todas as linhas de uma tabela que sãoduplicado de acordo com alguns campos, por exemplo, eles têm o mesmoCOLUMN_1, COLUMN_2 eCOLUMN_3 SELECT * FROM ( SELECT t.*, ROW_NUMBER() OVER (PARTITION BY ...
A filtragem por função da janela resulta no Postgresql
Ok, inicialmente isso foi apenas uma piada que tivemos com um amigo meu, mas isso se tornou uma questão técnica interessante :) Eu tenho o seguintestuff mesa: CREATE TABLE stuff ( id serial PRIMARY KEY, volume integer NOT NULL DEFAULT ...
Selecionando valor agregado positivo e ignorando negativo no Postgres SQL
Eu devo aplicar uma certa transformaçãofn(argument). Aquiargument é igual avalue, mas não quando é negativo. Quando você recebe uma primeira negativavalue, então você "espera" até que resuma com valores consecutivos e essa soma se torne positiva. ...
Funções da janela e mais agregação "local"
Suponha que eu tenha esta tabela: