Resultados de la búsqueda a petición "window-functions"
Función de avance / retraso condicional PostgreSQL?
Tengo una mesa 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:30Ahora, necesito un ...
Spark Window Functions requiere HiveContext?
Estoy probando un ejemplo de función de ventana en spark de este ...
Cómo agregar en una ventana de tiempo variable con grupos en Spark
Tengo algunos datos que quiero agrupar por una determinada columna, luego agrego una serie de campos basados en una ventana de tiempo variable del grupo. Aquí hay algunos datos de ejemplo: df = spark.createDataFrame([Row(date='2016-01-01', ...
Sesiónice una columna de números en grupos de 30 una vez que se alcanza un umbral en Teradata
Considere una columna que representa "tiempo entre eventos": (5, 40, 3, 6, 0, 9, 0, 4, 5, 18, 2, 4, 3, 2) Me gustaría agruparlos en cubos de 30, pero que se restablecen. Resultado deseado: (0, 1, 1, 1, 1, 1, 1, 1, 1, 2, 2, 2, 2, 2) Esto se ...
Funciones de ventana: last_value (ORDER BY ... ASC) igual que last_value (ORDER BY ... DESC)
Data de muestra CREATE TABLE test (id integer, session_ID integer, value integer) ; INSERT INTO test (id, session_ID, value) VALUES (0, 2, 100), (1, 2, 120), (2, 2, 140), (3, 1, 900), (4, 1, 800), (5, 1, 500) ;Consulta actual select id, ...
pyspark: cuenta distinta sobre una ventana
Acabo de intentar hacer un countDistinct sobre una ventana y obtuve este error: AnalysisException: u'Distinct window functions are not supported: count(distinct color#1926)¿Hay alguna manera de hacer un recuento distinto sobre una ventana ...
Función de ventana Spark SQL con condición compleja
Esto es probablemente más fácil de explicar a través del ejemplo. Supongamos que tengo un DataFrame de inicios de sesión de usuario en un sitio web, por ejemplo: scala> df.show(5) +----------------+----------+ | ...
Cálculo del costo promedio ponderado del stock de productos
Tengo que calcular el costo de stock de mis productos, por lo que para cada producto después de cada compra, tengo que volver a calcular elCosto promedio ponderado [http://en.wikipedia.org/wiki/Average_cost_method]. Tengo una vista que me trae ...
Filtrado de Django en funciones de Windows
Tengo dos modelos en Django, A y B. Cada A tiene varios B asignados y los B están ordenados, lo que se hace con un campo B.order_index que cuenta hacia arriba desde cero para cualquier A. Quiero escribir una consulta que verifique si hay alguna ...
Spark - ¿Ventana con recursividad? - Propagación condicional de valores entre filas
Tengo el siguiente marco de datos que muestra los ingresos de las 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| ...