E-MapReduce:Panduan Cepat

Prasyarat

Kluster Doris telah dibuat. Untuk informasi selengkapnya, lihat Buat kluster Doris.

Contoh

1. Masuk ke kluster menggunakan protokol Secure Shell (SSH). Untuk informasi selengkapnya, lihat Masuk ke kluster.

   Alamat IP publik dari node master tersedia di tab Node Management di bawah kelompok mesin emr_master di Konsol baru.

2. Jalankan perintah berikut untuk terhubung ke kluster.

   mysql -h127.0.0.1  -P 9031 -uroot

3. Jalankan perintah berikut untuk membuat dan memilih database.

   CREATE DATABASE IF NOT EXISTS load_test;
   USE load_test;

4. Jalankan perintah berikut untuk membuat tabel.

   CREATE TABLE insert_wiki_edit
   (
       event_time DATETIME,
       channel VARCHAR(32) DEFAULT '',
       user VARCHAR(128) DEFAULT '',
       is_anonymous TINYINT DEFAULT '0',
       is_minor TINYINT DEFAULT '0',
       is_new TINYINT DEFAULT '0',
       is_robot TINYINT DEFAULT '0',
       is_unpatrolled TINYINT DEFAULT '0',
       delta INT SUM DEFAULT '0',
       added INT SUM DEFAULT '0',
       deleted INT SUM DEFAULT '0'
   )
   AGGREGATE KEY(event_time, channel, user, is_anonymous, is_minor, is_new, is_robot, is_unpatrolled)
   PARTITION BY RANGE(event_time)
   (
       PARTITION p06 VALUES LESS THAN ('2015-09-12 06:00:00'),
       PARTITION p12 VALUES LESS THAN ('2015-09-12 12:00:00'),
       PARTITION p18 VALUES LESS THAN ('2015-09-12 18:00:00'),
       PARTITION p24 VALUES LESS THAN ('2015-09-13 00:00:00')
   )
   DISTRIBUTED BY HASH(user) BUCKETS 10
   PROPERTIES("replication_num" = "1");

5. Jalankan perintah berikut untuk mengimpor data uji.

   INSERT INTO insert_wiki_edit VALUES("2015-09-12 00:00:00","#en.wikipedia","GELongstreet",0,0,0,0,0,36,36,0),("2015-09-12 00:00:00","#ca.wikipedia","PereBot",0,1,0,1,0,17,17,0);

6. Jalankan perintah berikut untuk melakukan kueri data.

   select * from insert_wiki_edit;

   Output berikut dikembalikan.

   +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+
   | event_time          | channel       | user         | is_anonymous | is_minor | is_new | is_robot | is_unpatrolled | delta | added | deleted |
   +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+
   | 2015-09-12 00:00:00 | #en.wikipedia | GELongstreet |            0 |        0 |      0 |        0 |              0 |    36 |    36 |       0 |
   | 2015-09-12 00:00:00 | #ca.wikipedia | PereBot      |            0 |        1 |      0 |        1 |              0 |    17 |    17 |       0 |
   +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+
   2 rows in set (0.07 sec)