MaxCompute:Penulisan ulang kueri tampilan yang di-materialisasi

Contoh 1: Menulis ulang pernyataan kueri dengan kondisi filter

1. Buat tampilan yang di-materialisasi.

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

2. Tabel berikut membandingkan pernyataan kueri asli dengan pernyataan yang telah ditulis ulang berdasarkan tampilan yang di-materialisasi yang dibuat.

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

Contoh 2: Menulis ulang pernyataan kueri dengan fungsi agregat

Contoh 3: Menulis ulang pernyataan kueri dengan klausa JOIN

Ketiga jenis pernyataan di atas dapat dikombinasikan. Jika suatu pernyataan kueri memenuhi kondisi penulisan ulang, maka kueri tersebut dapat ditulis ulang.

Tujuan penulisan ulang kueri adalah untuk mempercepat eksekusi. MaxCompute memprioritaskan aturan penulisan ulang yang paling efektif. Jika penulisan ulang menambahkan operasi tanpa meningkatkan performa, MaxCompute tidak akan menggunakannya.

Contoh 4: Menulis ulang pernyataan kueri dengan klausa LEFT JOIN

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 membandingkan pernyataan kueri asli dengan pernyataan yang telah ditulis ulang berdasarkan tampilan yang di-materialisasi yang dibuat.

   Pernyataan kueri asli	Pernyataan kueri yang ditulis ulang
   SELECT t1.user_id, sum(t2.order_amout) 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;

Contoh 5: Menulis ulang pernyataan kueri dengan klausa UNION ALL

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 membandingkan pernyataan kueri asli dengan pernyataan yang telah ditulis ulang berdasarkan tampilan yang di-materialisasi yang dibuat.

   Pernyataan kueri asli	Pernyataan kueri yang ditulis ulang
   SELECT user_id, tran_amount FROM alipay_tran UNION ALL SELECT user_id, tran_amount FROM unionpay_tran;	SELECT user_id, total_amount FROM mv;

Contoh 6: Skenario

1. Skenario Contoh

   Asumsikan Anda memiliki tabel akses halaman bernama visit_records. Tabel ini mencatat ID halaman, ID pengguna, dan waktu akses untuk setiap kunjungan. Anda sering perlu melakukan kueri dan menganalisis jumlah kunjungan ke berbagai halaman.

   Dalam kasus ini, Anda dapat membuat tampilan yang di-materialisasi untuk tabel visit_records yang mengelompokkan data berdasarkan ID halaman dan menghitung jumlah kunjungan untuk setiap halaman. Kemudian, Anda dapat menjalankan kueri berdasarkan tampilan yang di-materialisasi ini.

   Struktur tabel 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. Tampilan ini mengelompokkan data 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 pernyataan kueri berikut.

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

   Saat Anda menjalankan kueri ini, MaxCompute secara otomatis menulis ulang kueri tersebut untuk menggunakan tampilan yang di-materialisasi count_mv dan membaca data agregat dari count_mv.

4. Jalankan perintah berikut untuk memeriksa apakah kueri telah ditulis ulang untuk menggunakan tampilan yang di-materialisasi.

   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

   Field Data source dalam hasil yang dikembalikan menunjukkan bahwa kueri membaca data dari tabel count_mv dalam proyek doc_test_dev. Hal ini menunjukkan bahwa tampilan yang di-materialisasi berfungsi dan penulisan ulang kueri berhasil.