全部产品
Search

搜索本产品

    Lindorm：Mulai Cepat

    文档中心

    Lindorm：Mulai Cepat

    更新时间：Jan 23, 2026

    Topik ini menjelaskan cara menggunakan SQL untuk membaca dan menulis data secara cepat dengan kelompok sumber daya Pemrosesan Analitik Online (OLAP) atau ekstrak, transformasi, dan muat (ETL) di Lindorm Compute Engine.

    Prasyarat

    • LindormTable telah diaktifkan. Untuk informasi selengkapnya, lihat Buat instans.

    • Anda telah mengaktifkan Lindorm Compute Engine. Untuk informasi selengkapnya, lihat Aktifkan layanan.

    • Anda telah menambahkan alamat IP klien ke daftar putih Lindorm. Untuk informasi selengkapnya, lihat Atur daftar putih.

    Gunakan kelompok sumber daya OLAP

    Kelompok sumber daya OLAP dalam compute engine menyediakan antarmuka akses yang kompatibel dengan MySQL. Kelompok ini dirancang untuk skenario analisis kueri dan memberikan tanggapan kueri berlatensi rendah dengan konkurensi tinggi. Setelah Anda membuat kelompok sumber daya OLAP, sumber daya komputasi khusus dialokasikan untuk memastikan respons kueri yang cepat.

    Langkah 1: Buat kelompok sumber daya OLAP

    1. Masuk ke Konsol Lindorm. Di pojok kiri atas halaman, pilih wilayah instans tersebut. Pada halaman Instances, klik ID instans target atau klik View Instance Details di kolom Actions untuk instans tersebut.

    2. Pada halaman Instance Details, buka bagian Configurations dan klik Resource Groups di kolom Compute Engine.image

    3. Pada halaman Resource Group Details, klik Create Resource Group dan konfigurasikan parameter berikut:

      Parameter

      Deskripsi

      Resource Group Type

      Pilih OLAP.

      Resource Group Name

      Nama kelompok sumber daya. Nama hanya boleh terdiri dari huruf kecil dan angka, serta panjangnya maksimal 63 karakter. Contoh: cg0.

      Node Specifications

      Pilih spesifikasi node.

      Working Nodes in Job

      Nilainya harus berada dalam rentang [4, 1024]. Nilai default adalah 4.

    4. Klik OK untuk membuat kelompok sumber daya.

      Catatan

      Proses pembuatan memerlukan waktu sekitar 20 menit.

    5. Pada halaman Resource Group Details, ketika status kelompok sumber daya yang baru dibuat berubah menjadi Running di bawah bagian Status and Description, arahkan kursor ke nama kelompok sumber daya OLAP untuk mendapatkan titik akhir internal VPC-nya, misalnya jdbc:mysql://ld-bp1dv48fk0yg0****-olap-proxy-ldps.lindorm.aliyuncs.com:9030.

    6. Setelah Anda mengonfigurasi klien MySQL, gunakan JDBC untuk terhubung ke titik akhir VPC dari kelompok sumber daya OLAP tersebut. Masuk menggunakan username dan password untuk LindormTable. Anda kemudian dapat menjalankan kueri SQL.

      mysql -hld-bp1dv48fk0yg0****-olap-proxy-ldps.lindorm.aliyuncs.com -P9030 -uroot -p

    Langkah 2: Akses data

    Akses data column store

    Column store adalah data lake yang menggunakan penyimpanan kolom dan kompatibel dengan ekosistem Iceberg. Data disimpan di file engine instans Lindorm. Anda dapat menggunakan kelompok sumber daya OLAP untuk menulis dan mengkueri data tersebut.

    Data column store disimpan dalam katalog lindorm_columnar. Katalog digunakan untuk mengidentifikasi sumber data yang berbeda. Katalog ini diakses secara default saat Anda terhubung menggunakan protokol MySQL. Anda juga dapat menjalankan perintah SET CATALOG lindorm_columnar; untuk secara eksplisit beralih ke katalog data column store.

    1. Buat dan gunakan database.

      -- Create a database.
CREATE DATABASE olapdemo;

-- Use the database.
USE olapdemo;

    2. Buat tabel dan tulis data ke dalamnya.

      -- Create a table.
CREATE TABLE test (id INT, name STRING) ENGINE = iceberg;

-- Insert data.
INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

    3. Kueri data.

      • Contoh 1:

        SELECT id, name FROM test WHERE id != 0;

        Hasil berikut dikembalikan:

        +------+--------+
| id   | name   |
+------+--------+
|    1 | Edison |
+------+--------+

      • Contoh 2:

        SELECT count(distinct name) FROM test;

        Hasil berikut dikembalikan:

        +----------------------+
| count(DISTINCT name) |
+----------------------+
|                    2 |
+----------------------+

      • Contoh 3:

        SELECT * FROM
 (SELECT id, name FROM test WHERE id != 0) t0
 JOIN
 (SELECT id, name FROM test WHERE id != 2) t1
 ON t0.id=t1.id;
        +------+--------+------+--------+
| id   | name   | id   | name   |
+------+--------+------+--------+
|    1 | Edison |    1 | Edison |
+------+--------+------+--------+

    4. Hapus tabel.

      DROP TABLE test;

    5. Hapus database.

      DROP DATABASE olapdemo;

    Akses data wide table

    Kelompok sumber daya OLAP mendukung kueri langsung terhadap data di LindormTable. Anda dapat memanfaatkan daya komputasinya untuk menjalankan kueri kompleks secara efisien. Kelompok sumber daya OLAP hanya mendukung operasi kueri. Kelompok ini tidak mendukung pembuatan tabel atau penulisan data ke LindormTable.

    Data LindormTable disimpan dalam katalog lindorm_table. Untuk mengakses data ini, Anda harus beralih ke katalog tersebut dengan menjalankan perintah SET CATALOG lindorm_table;.

    Jika Anda sudah memiliki wide table, lanjutkan ke langkah berikutnya. Jika belum, hubungkan ke LindormTable dan jalankan pernyataan berikut untuk membuat wide table bernama tb.

    -- Create a database.
CREATE DATABASE test; 

-- Use the database.
USE test; 

-- Create a data table and insert two rows of data.
CREATE TABLE tb (id varchar, name varchar, address varchar,  primary key(id, name)) ; 
UPSERT INTO tb (id, name, address) values ('001', 'Jack',  'hz'); 
UPSERT INTO tb (id, name, address) values ('002', 'Edison',  'bj');

    Pada Antarmuka baris perintah (CLI) MySQL yang terhubung ke kelompok sumber daya OLAP, jalankan pernyataan kueri berikut untuk mengakses data wide table.

    1. Beralih secara eksplisit ke sumber data dan gunakan database.

      -- Explicitly switch the data source.
SET CATALOG lindorm_table;

-- Use the test database.
USE test;

    2. Kueri data wide table.

      • Contoh 1:

        SELECT * FROM tb LIMIT 5;

        Hasil berikut dikembalikan:

        +------+--------+---------+
| id   | name   | address |
+------+--------+---------+
| 001  | Jack   | hz      |
| 002  | Edison | bj      |
+------+--------+---------+

      • Contoh 2:

        SELECT count(*) FROM tb;

        Hasil berikut dikembalikan:

        +----------+
| count(*) |
+----------+
|        2 |
+----------+

    Gunakan kelompok sumber daya ETL

    Kelompok sumber daya ETL dalam compute engine menyediakan Spark SQL arsitektur tanpa server untuk menjalankan kueri dan menulis data. Sumber daya diminta sesuai kebutuhan dan dilepas secara otomatis. Hal ini menjadikannya ideal untuk kueri yang jarang dilakukan atau pelaporan offline.

    Langkah 1: Aktifkan kelompok sumber daya

    1. Masuk ke Konsol Lindorm. Di pojok kiri atas halaman, pilih wilayah instans tersebut. Pada halaman Instances, klik ID instans target atau klik View Instance Details di kolom Actions untuk instans tersebut.

    2. Pada halaman Instance Details, buka bagian Configurations dan klik Resource Groups di kolom Compute Engine.image

    3. Pada halaman Resource Group Details, klik Create Resource Group dan konfigurasikan parameter berikut:

      Parameter

      Deskripsi

      Resource Group Type

      Pilih ETL.

      Resource Group Name

      Nama kelompok sumber daya. Nama hanya boleh terdiri dari huruf kecil dan angka, serta panjangnya maksimal 63 karakter. Contoh: cg0.

      Daily Resource Quota

      Jumlah maksimum Capacity Unit (CU) yang dapat dikonsumsi kelompok sumber daya per hari. Satuannya adalah CU*Hour. Nilai default adalah 100000.

      Penting

      Jika kuota terlampaui, pekerjaan akan segera dihapus. Untuk kelompok sumber daya yang memerlukan stabilitas tinggi, atur parameter ini ke 0. Nilai 0 berarti tidak ada batasan.

      The maximum number of CPU cores in the resource group.

      Jumlah maksimum core CPU untuk kelompok sumber daya. Nilai valid: [100, 100000].

      The maximum memory size in the resource group. Unit: GB.

      Ukuran memori maksimum untuk kelompok sumber daya. Nilai valid: [400 GB, 1000000 GB]. Tidak ada nilai default.

      Authorize Users

      Nilai default adalah *, yang mengizinkan semua pengguna mengakses kelompok sumber daya.

    4. Klik OK untuk membuat kelompok sumber daya.

    Langkah 2: Siapkan lingkungan

    Catatan

    Lingkungan berikut diterapkan pada Instance ECS yang berada dalam VPC yang sama dengan instans Lindorm.

    1. Instal Java Development Kit (JDK) versi 1.8 atau yang lebih baru.

    2. Unduh atau Spark.

    3. Ekstrak paket instalasi Spark.

    4. Atur variabel lingkungan SPARK_HOME ke path tempat Anda mengekstrak paket tersebut.

    export SPARK_HOME=/path/to/spark/;

    1. Edit file konfigurasi $SPARK_HOME/conf/beeline.conf.

      • endpoint: JDBC URL dari compute engine Lindorm. Untuk informasi selengkapnya tentang cara mengambil URL tersebut, lihat Lihat titik akhir.

      • user: Username untuk mengakses LindormTable.

      • password: Password yang sesuai dengan username tersebut.

      • shareResource: Menentukan apakah sumber daya komputasi dibagikan di antara beberapa session untuk pengguna yang sama. Nilai default adalah true.

      • compute-group: Nama kelompok sumber daya ETL yang digunakan oleh compute engine. Jika Anda tidak mengatur parameter ini, nilai default-nya adalah default.

    2. Buka direktori $SPARK_HOME/bin dan jalankan perintah ./beeline. Perintah tersebut menampilkan output berikut:

      Welcome to Lindorm Distributed Processing System (LDPS) !!!
Initializing environment. It might take minutes ...
Environemnt prepared. You may visit your jdbc cluster by below url:
http://alb-boqak6zfns5gzx****.cn-hangzhou.alb.aliyuncsslb.com/proxy/75ce76086b61470da7046bd4c2b7****
Please note -- you are sharing this JDBC cluster between SQL sessions from the same user.
The cluster will be released by auto if idle for 4 hours.
You may also kill it manually by visiting above web url and clicking 'kill' in tab of 'Query Engine'
lindorm-beeline>

      Pada sesi interaktif, masukkan pernyataan SQL untuk menjalankan operasi tulis atau kueri.

      Catatan

      Gunakan tautan yang dikembalikan, http://alb-boqak6zfns5gzx****.cn-hangzhou.alb.aliyuncsslb.com/proxy/75ce76086b61470da7046bd4c2b7****, untuk mengakses Spark UI untuk compute engine.

    Langkah 3: Akses data

    Akses data column store

    Column store adalah data lake yang menggunakan penyimpanan kolom dan kompatibel dengan ekosistem Iceberg. Data disimpan di file engine instans Lindorm. Anda dapat menggunakan Spark SQL untuk menulis dan mengkueri data tersebut.

    Data column store disimpan dalam katalog lindorm_columnar. Katalog digunakan untuk mengidentifikasi sumber data yang berbeda. Katalog ini diakses secara default saat Anda terhubung menggunakan protokol MySQL. Anda juga dapat menjalankan perintah SET CATALOG lindorm_columnar; untuk secara eksplisit beralih ke katalog data column store.

    1. Buat dan gunakan database.

      -- Create a database
CREATE DATABASE etldemo;

-- Use the database
USE etldemo;

    2. Buat tabel data dan tulis data ke dalamnya.

      -- Create a table
CREATE TABLE test (id INT, name STRING);

-- Insert data
INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

    3. Kueri data.

      • Contoh 1:

        SELECT id, name FROM test WHERE id != 0;

        Hasil berikut dikembalikan:

        +------+--------+
| id   | name   |
+------+--------+
|    1 | Edison |
+------+--------+

      • Contoh 2:

        SELECT count(distinct name) FROM test;

        Hasil berikut dikembalikan:

        +----------------------+
| count(DISTINCT name) |
+----------------------+
|                    2 |
+----------------------+

      • Contoh 3:

        SELECT * FROM
 (SELECT id, name FROM test WHERE id != 0) t0
 JOIN
 (SELECT id, name FROM test WHERE id != 2) t1
 ON t0.id=t1.id;
        +------+--------+------+--------+
| id   | name   | id   | name   |
+------+--------+------+--------+
|    1 | Edison |    1 | Edison |
+------+--------+------+--------+

    4. Hapus tabel.

      DROP TABLE test;

    5. Hapus database.

      DROP DATABASE etldemo;

    Akses data wide table

    Anda dapat menggunakan koneksi Spark SQL dalam kelompok sumber daya ETL untuk mengkueri data di LindormTable. Anda dapat memanfaatkan sumber daya komputasi elastis untuk menjalankan kueri dan komputasi kompleks pada data wide table. Koneksi Spark SQL tidak mendukung pernyataan Data Definition Language (DDL), seperti membuat atau menghapus tabel di LindormTable. Namun, Anda dapat menggunakannya untuk mengkueri data.

    Data LindormTable disimpan dalam katalog lindorm_table. Untuk mengakses data ini, Anda harus beralih ke katalog tersebut dengan menjalankan perintah SET CATALOG lindorm_table;.

    Jika Anda sudah memiliki wide table, lanjutkan ke langkah berikutnya. Jika belum, hubungkan ke LindormTable dan jalankan pernyataan berikut untuk membuat wide table bernama tb.

    -- Create a database.
CREATE DATABASE test; 

-- Use the database.
USE test; 

-- Create a data table and insert two rows of data.
CREATE TABLE tb (id varchar, name varchar, address varchar,  primary key(id, name)) ; 
UPSERT INTO tb (id, name, address) values ('001', 'Jack',  'hz'); 
UPSERT INTO tb (id, name, address) values ('002', 'Edison',  'bj');

    Pada sesi interaktif lindorm-beeline, jalankan pernyataan kueri berikut untuk mengakses data wide table.

    1. Beralih secara eksplisit ke sumber data dan gunakan database.

      -- Explicitly switch the data source.
SET CATALOG lindorm_table;

-- Use the test database.
USE test;

    2. Kueri data wide table.

      Contoh 1:

      SELECT * FROM tb LIMIT 5;

      Hasil berikut dikembalikan:

      +------+--------+---------+
| id   | name   | address |
+------+--------+---------+
| 001  | Jack   | hz      |
| 002  | Edison | bj      |
+------+--------+---------+

      Contoh 2:

      SELECT count(*) FROM tb;

      Hasil berikut dikembalikan:

      +-----------+
| count(1)  |
+-----------+
| 2         |
+-----------+