MaxCompute:Penulisan ulang kueri tampilan yang di-materialisasi

Example 1: Rewrite with filter conditions

1. Buat tampilan yang di-materialisasi.

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

2. Tabel berikut menyediakan contoh penulisan ulang untuk tampilan yang di-materialisasi.

   Original query	Rewritten query
   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;	Penulisan ulang gagal karena tampilan yang di-materialisasi tidak berisi kolom d.
   SELECT d, e FROM src WHERE a=10;	Penulisan ulang gagal karena tampilan yang di-materialisasi tidak berisi kolom d dan e.
   SELECT a, b FROM src WHERE a=1;	Penulisan ulang gagal karena tampilan yang di-materialisasi tidak berisi data dengan a=1.

Example 2: Rewrite with aggregate functions

Example 3: Rewrite with a JOIN clause

Ketiga skenario penulisan ulang JOIN ini dapat dikombinasikan.

Karena tujuan penulisan ulang kueri tampilan yang di-materialisasi adalah untuk mempercepat kueri, MaxCompute memprioritaskan aturan penulisan ulang yang memberikan performa terbaik. Aturan tidak diterapkan jika menghasilkan operasi yang menyebabkan akselerasi buruk.

Example 4: Rewrite with a LEFT JOIN clause

1. Buat tampilan yang di-materialisasi.

   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. Tabel berikut menunjukkan cara kueri ditulis ulang berdasarkan tampilan yang di-materialisasi.

   Original query	Rewritten query
   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;

Example 5: Rewrite with a UNION ALL clause

1. Buat tampilan yang di-materialisasi.

   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. Tabel berikut menunjukkan cara kueri ditulis ulang berdasarkan tampilan yang di-materialisasi.

   Original query	Rewritten query
   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;

Example 6: Use case

1. Scenario

   Pertimbangkan tabel kunjungan halaman bernama visit_records yang mencatat ID halaman, ID pengguna, dan waktu kunjungan untuk setiap kunjungan. Tugas analisis yang sering dilakukan adalah menghitung jumlah kunjungan untuk halaman berbeda.

   Dalam situasi ini, Anda dapat membuat tampilan yang di-materialisasi pada visit_records yang dikelompokkan berdasarkan ID halaman dan menghitung jumlah kunjungan untuk setiap halaman. Anda kemudian dapat menjalankan kueri selanjutnya terhadap tampilan yang di-materialisasi ini.

   Struktur visit_records adalah sebagai berikut:

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

2. Buat tampilan yang di-materialisasi.

   -- Buat tampilan yang di-materialisasi untuk tabel visit_records yang dikelompokkan berdasarkan ID halaman dan menghitung jumlah kunjungan untuk setiap halaman.
   
   CREATE MATERIALIZED VIEW count_mv AS SELECT page_id, count(*) FROM visit_records GROUP BY page_id;

3. Jalankan kueri berikut:

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

   Ketika pernyataan kueri ini dieksekusi, MaxCompute secara otomatis mencocokkan tampilan yang di-materialisasi count_mv dan membaca data yang telah di-agregasi dari count_mv.

4. Untuk memverifikasi bahwa kueri ditulis ulang menggunakan tampilan yang di-materialisasi, jalankan perintah EXPLAIN berikut:

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

   Hasil berikut dikembalikan:

   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

   Data source dalam hasil yang dikembalikan menunjukkan bahwa tabel yang dibaca oleh kueri adalah doc_test_dev project's count_mv. Hal ini menunjukkan bahwa tampilan yang di-materialisasi efektif dan penulisan ulang kueri berhasil.