MaxCompute:Reescritura de consultas con vistas materializadas

Ejemplo 1: Reescritura con condiciones de filtro

1. Cree una vista materializada.

   CREATE MATERIALIZED VIEW mv AS SELECT a,b,c FROM src WHERE a>5;

2. A continuación se muestran ejemplos de reescritura para esta vista materializada.

   Consulta original	Consulta reescrita
   SELECT a,b FROM src WHERE a>5;	SELECT a,b FROM mv;
   SELECT a, b FROM src WHERE a=10;	SELECT a,b FROM mv WHERE a=10;
   SELECT a, b FROM src WHERE a=10 AND b='3';	SELECT a,b FROM mv WHERE a=10 AND b=3;
   SELECT a, b FROM src WHERE a>3;	(SELECT a,b FROM src WHERE a>3 AND a<=5) UNION (SELECT a,b FROM mv);
   SELECT a, b FROM src WHERE a=10 AND d=4;	La reescritura falla porque la vista materializada no contiene la columna d.
   SELECT d, e FROM src WHERE a=10;	La reescritura falla porque la vista materializada no contiene las columnas d y e.
   SELECT a, b FROM src WHERE a=1;	La reescritura falla porque la vista materializada no contiene datos donde a=1.

Ejemplo 2: Reescritura con funciones de agregación

Ejemplo 3: Reescritura con una cláusula JOIN

Estos tres escenarios de reescritura de JOIN se pueden combinar.

Dado que el objetivo de la reescritura de consultas con vistas materializadas es acelerar las consultas, MaxCompute prioriza las reglas de reescritura que ofrecen el mejor rendimiento. Una regla no se aplica si introduce operaciones que resultarían en una aceleración deficiente.

Ejemplo 4: Reescritura con una cláusula LEFT JOIN

1. Cree una vista materializada.

   CREATE MATERIALIZED VIEW mv LIFECYCLE 7(
           user_id,
           job,
           total_amount
   ) AS SELECT t1.user_id, t1.job, sum(t2.order_amount) AS total_amount 
         FROM user_info AS t1 LEFT JOIN sale_order AS t2 ON t1.user_id=t2.user_id GROUP BY t1.user_id;

2. En la siguiente tabla se muestra cómo se reescribe una consulta a partir de la vista materializada.

   Consulta original	Consulta reescrita
   SELECT t1.user_id, sum(t2.order_amount) AS total_amount FROM user_info AS t1 LEFT JOIN sale_order AS t2 ON t1.user_id=t2.user_id GROUP BY t1.user_id;	SELECT user_id, total_amount FROM mv;

Ejemplo 5: Reescritura con una cláusula UNION ALL

1. Cree una vista materializada.

   CREATE MATERIALIZED VIEW mv LIFECYCLE 7( 
           user_id, 
           tran_amount, 
           tran_date 
   ) AS SELECT user_id, tran_amount, tran_date FROM alipay_tran UNION ALL 
   SELECT user_id, tran_amount, tran_date FROM unionpay_tran;

2. En la siguiente tabla se muestra cómo se reescribe una consulta a partir de la vista materializada.

   Consulta original	Consulta reescrita
   SELECT user_id, tran_amount FROM alipay_tran UNION ALL SELECT user_id, tran_amount FROM unionpay_tran;	SELECT user_id, tran_amount FROM mv;

Ejemplo 6: Caso de uso

1. Escenario

   Considere una tabla de visitas a páginas llamada visit_records que registra el identificador de página, el identificador de usuario y la hora de cada visita. Una tarea de análisis frecuente consiste en contar el número de visitas para distintas páginas.

   En esta situación, cree una vista materializada sobre visit_records que agrupe por identificador de página y cuente las visitas de cada una. Después, ejecute las consultas posteriores sobre esta vista materializada.

   La estructura de visit_records es la siguiente:

   +------------------------------------------------------------------------------------+
   | Field           | Type       | Label | Comment                                     |
   +------------------------------------------------------------------------------------+
   | page_id         | string     |       |                                             |
   | user_id         | string     |       |                                             |
   | visit_time      | string     |       |                                             |
   +------------------------------------------------------------------------------------+

2. Cree una vista materializada.

   -- Create a materialized view for the visit_records table that groups by page ID and counts the visits for each page.
   
   CREATE MATERIALIZED VIEW count_mv AS SELECT page_id, count(*) FROM visit_records GROUP BY page_id;

3. Ejecute la siguiente consulta:

   SET odps.sql.materialized.view.enable.auto.rewriting=true; 
   SELECT page_id, count(*) FROM visit_records GROUP BY page_id;

   Cuando se ejecuta esta instrucción de consulta, MaxCompute asocia automáticamente la vista materializada count_mv y lee los datos preagregados desde count_mv.

4. Para comprobar que la consulta se reescribió mediante la vista materializada, ejecute el siguiente comando EXPLAIN:

   EXPLAIN SELECT page_id, count(*) FROM visit_records GROUP BY page_id;

   Se devuelve el siguiente resultado:

   job0 is root job
   
   In Job job0:
   root Tasks: M1
   
   In Task M1:
       Data source: doc_test_dev.count_mv
       TS: doc_test_dev.count_mv
           FS: output: Screen
               schema:
                 page_id (string)
                 _c1 (bigint)
   
   OK

   El campo Data source del resultado devuelto indica que la tabla leída por la consulta es count_mv del proyecto doc_test_dev. Esto confirma que la vista materializada funciona correctamente y que la reescritura de la consulta fue exitosa.