Lindorm:クイックスタート

列ストアデータへのアクセス

列ストアは、列指向ストレージを使用し、Iceberg エコシステムと互換性のあるデータレイクです。データは Lindorm インスタンスのファイルエンジンに保存されます。OLAP リソースグループを使用して、データの書き込みとクエリができます。

列ストアデータは lindorm_columnar カタログに保存されます。カタログは、異なるデータソースを識別するために使用されます。MySQL プロトコルを使用して接続すると、このカタログにデフォルトでアクセスします。SET CATALOG lindorm_columnar; コマンドを実行して、明示的に列ストアデータカタログに切り替えることもできます。

1. データベースを作成して使用します。

   -- データベースを作成します。
   CREATE DATABASE olapdemo;
   
   -- データベースを使用します。
   USE olapdemo;

2. テーブルを作成し、データを書き込みます。

   -- テーブルを作成します。
   CREATE TABLE test (id INT, name STRING) ENGINE = iceberg;
   
   -- データを挿入します。
   INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

3. データをクエリします。

   • 例 1：

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

     次の結果が返されます：

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

   • 例 2：

     SELECT count(distinct name) FROM test;

     次の結果が返されます：

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

   • 例 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. テーブルを削除します。

   DROP TABLE test;

5. データベースを削除します。

   DROP DATABASE olapdemo;

ワイドテーブルデータへのアクセス

OLAP リソースグループは、LindormTable のデータを直接クエリすることをサポートしています。その計算能力を使用して、複雑なクエリを効率的に実行できます。OLAP リソースグループはクエリ操作のみをサポートし、LindormTable へのテーブル作成やデータ書き込みはサポートしていません。

LindormTable データは lindorm_table カタログに保存されます。このデータにアクセスするには、SET CATALOG lindorm_table; コマンドを実行してカタログを切り替える必要があります。

-- データベースを作成します。
CREATE DATABASE test; 

-- データベースを使用します。
USE test; 

-- データテーブルを作成し、2行のデータを挿入します。
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'); 

列のストアデータへのアクセス

列のストアは、カラムナストレージを使用し、Iceberg エコシステムと互換性のあるデータレイクです。データは Lindorm インスタンスのファイルエンジンに保存されます。Spark SQL を使用して、データの書き込みとクエリを実行できます。

列のストアデータは lindorm_columnar カタログに保存されます。カタログは、さまざまなデータソースを識別するために使用されます。このカタログは、MySQL プロトコルを使用して接続する際にデフォルトでアクセスされます。SET CATALOG lindorm_columnar; コマンドを実行して、明示的に列のストアデータカタログに切り替えることもできます。

1. データベースを作成して使用します。

   -- データベースの作成
   CREATE DATABASE etldemo;
   
   -- データベースの使用
   USE etldemo;

2. データテーブルを作成し、データを書き込みます。

   -- テーブルの作成
   CREATE TABLE test (id INT, name STRING);
   
   -- データの挿入
   INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

3. データをクエリします。

   • 例 1：

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

     次の結果が返されます。

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

   • 例 2：

     SELECT count(distinct name) FROM test;

     次の結果が返されます。

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

   • 例 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. テーブルを削除します。

   DROP TABLE test;

5. データベースを削除します。

   DROP DATABASE etldemo;

ワイドテーブルデータへのアクセス

ETL リソースグループの Spark SQL 接続を使用して、LindormTable のデータをクエリできます。弾力性のある計算リソースを使用して、ワイドテーブルデータに対して複雑なクエリや計算を実行できます。Spark SQL 接続は、LindormTable でのテーブルの作成や削除などのデータ定義言語 (DDL) 文をサポートしていません。ただし、データのクエリには使用できます。

LindormTable データは lindorm_table カタログに保存されます。このデータにアクセスするには、SET CATALOG lindorm_table; コマンドを実行してカタログを切り替える必要があります。

-- データベースの作成
CREATE DATABASE test; 

-- データベースの使用
USE test; 

-- データテーブルを作成し、2行のデータを挿入
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 対話型セッションで、次のクエリ文を実行してワイドテーブルデータにアクセスします。

1. データソースを明示的に切り替え、データベースを使用します。

   -- データソースを明示的に切り替え
   SET CATALOG lindorm_table;
   
   -- test データベースの使用
   USE test;

2. ワイドテーブルデータをクエリします。

   例 1：

   SELECT * FROM tb LIMIT 5;

   次の結果が返されます。

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

   例 2：

   SELECT count(*) FROM tb;

   次の結果が返されます。

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