Data Engineer
dict1 = {(1,2, [3,4]): 0} var = 1,
МТС¿En qué se diferencia RANK de DENSE_RANK?
Aston¿Has tenido experiencia trabajando con Table Engine Join en ClickHouse?
¿Tiene sentido usar CTE si se usa solo una vez en la consulta?
МВидео¿Existen otros mecanismos de control de shuffle además de coalesce/repartition?
Proporcione un ejemplo de una tarea típica de escritura de DAG en Airflow.
Лига Цифровой Экономики¿En qué casos se aplica la normalización y en cuáles la desnormalización?
¿Cómo ves tu desarrollo en el nuevo equipo y qué tareas te gustaría realizar más?
Los 3 principales criterios para elegir una oferta si hay varias propuestas.
importar clickhouse_driver from airflow.hooks.base import * def get_clickhouse_client(): conn = BaseHook.get_connection("clickhouse_default") return clickhouse_driver.Client( host=conn.host, port=conn.port, user=conn.login, password=conn.password, database=conn.schema )
Resultado final: | customer_id | gap_days | |-------------|----------| | 1 | 123 | | 2 | 120 | con cte como( seleccionar order_id, customer_id, order_dt, lag(order_dt) sobre(partición por customer_id ordenar por order_dt) como prev_order_ft, datediff(día, prev_order_ft, order_dt) como gap_days de Orders ) seleccionar customer_id, max(gap_days) como gap_days de cte donde gap_days > 60 grupo por customer_id
Островок¿Qué es un plan de consultas? ¿Para qué sirven?
¿Cuáles son los riesgos de calidad de los datos?
Островок¿Se realizó un registro adicional además de los registros de Airflow?
Лига Цифровой Экономики¿Cuál fue la última tarea en Python que resolvió en producción?
Cuéntame sobre un par de tus tareas más importantes relacionadas con la calidad de los datos.
СБЕР¿Cómo afecta el tamaño de las partículas a la tabla de ClickHouse?
En PostgreSQL, el encabezado de versión de la fila incluye el parámetro xmax. ¿Cuál es su función en la gestión de transacciones? - Para crear un identificador único de fila en la tabla - Para verificar la visibilidad de la fila por otras transacciones - Para indicar el número de transacción que eliminó o actualizó la fila - Para bloquear la fila contra cambios simultáneos por varias transacciones - Para indicar el valor máximo que puede ser registrado en una columna numérica
¿Creaste trabajos de dbt en Airflow manualmente o los automatizaste de alguna manera, había plantillas?
МВидео¿Tiene ofertas o propuestas en competencia de otras empresas?