Resultados de la búsqueda a petición "window-functions"
Uso de funciones de ventanas en Spark
Estoy tratando de usar rowNumber en los marcos de datos de Spark. Mis consultas funcionan como se esperaba en Spark Shell. Pero cuando los escribo en eclipse y compilo un frasco, me enfrento a un error 16/03/23 05:52:43 ERROR ApplicationMaster: ...
¿Cómo "restablecer" la ejecución de SUM después de que alcanza un umbral?
Escribí una consulta que crea dos columnas:the_day, y elamount_raised En ese día. Esto es lo que tengo: [/imgs/SlNQH.png] Y me gustaría agregar una columna que tenga una suma continua deamount_raised: [/imgs/EKrQf.png] En definitiva, me ...
función de ventana first_value en pyspark
Estoy usando pyspark 1.5 obteniendo mis datos de las tablas de Hive e intentando usar las funciones de ventanas. De acuerdo aesta [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] existe una función ...
Total acumulado sobre el grupo repetitivo por elementos según el tiempo en Oracle SQL
Mi primer post, así que tengan paciencia conmigo. Quiero sumar en función de un valor dividido por fechas, pero solo quiero la suma de las fechas, no del grupo por artículo en total. He estado trabajando en esto durante días, tratando de evitar ...
Función Apache Spark Window con columna anidada
No estoy seguro de que esto sea un error (o simplemente una sintaxis incorrecta). Busqué alrededor y no vi esto mencionado en otra parte, así que pregunto aquí antes de presentar un informe de error. Estoy tratando de usar una función de Windows ...
Función Oracle Lag con parámetro dinámico
Tengo un problema especifico Tengo una tabla que contiene valores no válidos. Necesito reemplazar los valores no válidos (aquí0) con el valor anterior que es mayor que0. La dificultad es que no es apropiado para mí usar una actualización o un ...
Funciones de ventana de chispa - rango entre fechas
Estoy teniendo un Spark SQLDataFrame con datos y lo que intento obtener es todas las filas que preceden a la fila actual en un rango de fechas dado. Entonces, por ejemplo, quiero tener todas las filas de 7 días anteriores a la fila dada. Descubrí ...
Función de tabla cruzada en Postgres que devuelve una salida de una fila cuando espero varias filas
Actualmente tengo una mesam del siguiente 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 1Quiero crear la siguiente tabla: id scenario period 1 2 3 4 2 1 1 1 2 1 2 1 ...
SparkSQL - ¿Función de retraso?
Veo en estoPublicación de DataBricks [https://databricks.com/blog/2015/07/15/introducing-window-functions-in-spark-sql.html] , hay soporte para funciones de ventana en SparkSql, en particular estoy tratando de usar la función de ventana lag ...
Spark y SparkSQL: ¿Cómo imitar la función de ventana?
DescripciónDado un marco de datosdf id | date --------------- 1 | 2015-09-01 2 | 2015-09-01 1 | 2015-09-03 1 | 2015-09-04 2 | 2015-09-04Quiero crear un contador o índice en ejecución, agrupados por la misma identificación yordenado por fecha en ...