Lindorm:Hızlı başlangıç

Sütun deposu verilerine erişme

Sütun deposu, Iceberg ekosistemiyle uyumlu, sütunsal depolama üzerine inşa edilmiş bir veri gölüdür. Veriler Lindorm örneğinin dosya motorunda saklanır.

lindorm_columnar kataloğu varsayılan olarak seçilidir. Buna açıkça geçiş yapmak için şu komutu çalıştırın:

SET CATALOG lindorm_columnar;

Aşağıdaki adımlarda bir veritabanı oluşturma, veri yazma ve örnek sorgular çalıştırma işlemleri gösterilmektedir.

1. Bir veritabanı oluşturun ve kullanın.

   -- Create a database.
   CREATE DATABASE olapdemo;
   
   -- Use the database.
   USE olapdemo;

2. Bir tablo oluşturun ve veri yazın.

   -- Create a table.
   CREATE TABLE test (id INT, name STRING) ENGINE = iceberg;
   
   -- Insert data.
   INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

3. Verileri sorgulayın. Örnek 1 — koşula göre filtreleme:

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

   Sonuç:

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

   Örnek 2 — toplama:

   SELECT count(distinct name) FROM test;

   Sonuç:

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

   Örnek 3 — birleştirme:

   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;

   Sonuç:

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

4. Temizlik yapın.

   DROP TABLE test;
   DROP DATABASE olapdemo;

Geniş tablo verilerine erişme

OLAP kaynak grubu, özel hesaplama düğümlerini kullanarak LindormTable verilerini sorgulayabilir. Yalnızca okuma işlemleri desteklenir; OLAP kaynak grubu aracılığıyla LindormTable üzerinde tablo oluşturamaz veya veri yazamazsınız.

Sorgulamadan önce geniş tablo kataloğuna geçiş yapın:

SET CATALOG lindorm_table;

Zaten bir geniş tablonuz varsa sorgulama adımlarına geçin. Aksi takdirde LindormTable'a bağlanın ve örnek bir tablo oluşturun:

-- Create a database.
CREATE DATABASE test;

-- Use the database.
USE test;

-- Create a table and insert two rows.
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');

OLAP kaynak grubuna bağlı MySQL komut satırı arabiriminde (CLI) aşağıdaki adımları uygulayın.

1. Veri kaynağını değiştirin ve veritabanını seçin.

   -- Switch to the wide table catalog.
   SET CATALOG lindorm_table;
   
   -- Use the test database.
   USE test;

2. Geniş tablo verilerini sorgulayın. Örnek 1 — satırları getirme:

   SELECT * FROM tb LIMIT 5;

   Sonuç:

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

   Örnek 2 — satır sayısını hesaplama:

   SELECT count(*) FROM tb;

   Sonuç:

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

Sütun deposu verilerine erişme

Sütun deposu, Iceberg ekosistemiyle uyumlu, sütunsal depolama üzerine inşa edilmiş bir veri gölüdür. Veriler Lindorm örneğinin dosya motorunda saklanır. Bu verilere yazmak ve bunları sorgulamak için Spark SQL kullanabilirsiniz.

lindorm_columnar kataloğu varsayılan olarak seçilidir. Buna açıkça geçiş yapmak için şu komutu çalıştırın:

SET CATALOG lindorm_columnar;

Aşağıdaki adımlarda bir veritabanı oluşturma, veri yazma ve örnek sorgular çalıştırma işlemleri gösterilmektedir.

1. Bir veritabanı oluşturun ve kullanın.

   -- Create a database.
   CREATE DATABASE etldemo;
   
   -- Use the database.
   USE etldemo;

2. Bir tablo oluşturun ve veri yazın.

   -- Create a table.
   CREATE TABLE test (id INT, name STRING);
   
   -- Insert data.
   INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

3. Verileri sorgulayın. Örnek 1 — koşula göre filtreleme:

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

   Sonuç:

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

   Örnek 2 — toplama:

   SELECT count(distinct name) FROM test;

   Sonuç:

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

   Örnek 3 — birleştirme:

   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;

   Sonuç:

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

4. Temizlik yapın.

   DROP TABLE test;
   DROP DATABASE etldemo;

Geniş tablo verilerine erişme

ETL kaynak grubundaki Spark SQL bağlantıları, esnek hesaplama kaynaklarını kullanarak LindormTable verilerini sorgulayabilir. Bu bağlantı üzerinden LindormTable için CREATE TABLE veya DROP TABLE gibi Veri Tanımlama Dili (DDL) ifadeleri desteklenmez. Yalnızca sorgulama ve hesaplama işlemleri için kullanın.

Sorgulamadan önce geniş tablo kataloğuna geçiş yapın:

SET CATALOG lindorm_table;

Zaten bir geniş tablonuz varsa sorgulama adımlarına geçin. Aksi takdirde LindormTable'a bağlanın ve örnek bir tablo oluşturun:

-- Create a database.
CREATE DATABASE test;

-- Use the database.
USE test;

-- Create a table and insert two rows.
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');

lindorm-beeline oturumunda aşağıdaki adımları uygulayın.

1. Veri kaynağını değiştirin ve veritabanını seçin.

   -- Switch to the wide table catalog.
   SET CATALOG lindorm_table;
   
   -- Use the test database.
   USE test;

2. Geniş tablo verilerini sorgulayın. Örnek 1 — satırları getirme:

   SELECT * FROM tb LIMIT 5;

   Sonuç:

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

   Örnek 2 — satır sayısını hesaplama:

   SELECT count(*) FROM tb;

   Sonuç:

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