MaxCompute:Reescrita de consultas em materialized views

Exemplo 1: Reescrita com condições de filtro

1. Crie uma materialized view.

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

2. A tabela a seguir apresenta exemplos de reescrita para a materialized view.

   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;	A reescrita falha porque a materialized view não contém a coluna d.
   SELECT d, e FROM src WHERE a=10;	A reescrita falha porque a materialized view não contém as colunas d e e.
   SELECT a, b FROM src WHERE a=1;	A reescrita falha porque a materialized view não contém dados onde a=1.

Exemplo 2: Reescrita com funções de agregação

Exemplo 3: Reescrita com cláusula JOIN

É possível combinar esses três cenários de reescrita de JOIN.

Como o objetivo da reescrita de consultas em materialized views é acelerar as consultas, o MaxCompute prioriza regras de reescrita que oferecem o melhor desempenho. Uma regra não é aplicada se introduzir operações que resultem em baixa aceleração.

Exemplo 4: Reescrita com cláusula LEFT JOIN

1. Crie uma materialized view.

   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. A tabela a seguir mostra como uma consulta é reescrita com base na materialized view.

   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;

Exemplo 5: Reescrita com cláusula UNION ALL

1. Crie uma materialized view.

   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. A tabela a seguir mostra como uma consulta é reescrita com base na materialized view.

   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;

Exemplo 6: Caso de uso

1. Cenário

   Considere uma tabela de visitas a páginas chamada visit_records que registra o ID da página, o ID do usuário e o horário de cada visita. Uma tarefa frequente de análise é contar o número de visitas para diferentes páginas.

   Nessa situação, crie uma materialized view em visit_records que agrupe por ID da página e conte as visitas de cada página. Em seguida, execute consultas subsequentes nessa materialized view.

   A estrutura de visit_records é a seguinte:

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

2. Crie uma materialized view.

   -- 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. Execute a seguinte consulta:

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

   Ao executar essa instrução de consulta, o MaxCompute corresponde automaticamente à materialized view count_mv e lê os dados pré-agregados de count_mv.

4. Para verificar se a consulta foi reescrita usando a materialized view, execute o seguinte comando EXPLAIN:

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

   O resultado retornado é:

   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

   O campo Data source no resultado retornado mostra que a tabela lida pela consulta é a count_mv do projeto doc_test_dev. Isso indica que a materialized view está ativa e a reescrita da consulta foi bem-sucedida.