Lindorm:Guia de início rápido

Acessar dados de armazenamento colunar

O armazenamento colunar é um data lake baseado em armazenamento colunar, compatível com o ecossistema Iceberg. Os dados ficam armazenados no mecanismo de arquivos da instância Lindorm.

O catálogo lindorm_columnar é selecionado por padrão. Para alternar para ele explicitamente, execute:

SET CATALOG lindorm_columnar;

As etapas a seguir criam um banco de dados, gravam dados e executam consultas de exemplo.

1. Crie e utilize um banco de dados.

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

2. Crie uma tabela e insira dados.

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

3. Consulte os dados. Exemplo 1 — filtrar por condição:

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

   Resultado:

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

   Exemplo 2 — agregação:

   SELECT count(distinct name) FROM test;

   Resultado:

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

   Exemplo 3 — junção:

   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;

   Resultado:

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

4. Limpe os recursos.

   DROP TABLE test;
   DROP DATABASE olapdemo;

Acessar dados de tabela larga

O grupo de recursos OLAP pode consultar dados do LindormTable usando seus nós de computação dedicados. Apenas operações de leitura são suportadas — não é possível criar tabelas ou gravar dados no LindormTable por meio do grupo de recursos OLAP.

Alterne para o catálogo de tabela larga antes de consultar:

SET CATALOG lindorm_table;

Se você já possui uma tabela larga, pule para as etapas de consulta. Caso contrário, conecte-se ao LindormTable e crie uma tabela de exemplo:

-- 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');

Na interface de linha de comando (CLI) do MySQL conectada ao grupo de recursos OLAP, execute as etapas a seguir.

1. Altere a fonte de dados e selecione o banco de dados.

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

2. Consulte dados da tabela larga. Exemplo 1 — recuperar linhas:

   SELECT * FROM tb LIMIT 5;

   Resultado:

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

   Exemplo 2 — contar linhas:

   SELECT count(*) FROM tb;

   Resultado:

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

Acessar dados de armazenamento colunar

O armazenamento colunar é um data lake baseado em armazenamento colunar, compatível com o ecossistema Iceberg. Os dados ficam armazenados no mecanismo de arquivos da instância Lindorm. Você pode usar Spark SQL para gravar e consultar esses dados.

O catálogo lindorm_columnar é selecionado por padrão. Para alternar para ele explicitamente, execute:

SET CATALOG lindorm_columnar;

As etapas a seguir criam um banco de dados, gravam dados e executam consultas de exemplo.

1. Crie e utilize um banco de dados.

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

2. Crie uma tabela e insira dados.

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

3. Consulte os dados. Exemplo 1 — filtrar por condição:

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

   Resultado:

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

   Exemplo 2 — agregação:

   SELECT count(distinct name) FROM test;

   Resultado:

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

   Exemplo 3 — junção:

   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;

   Resultado:

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

4. Limpe os recursos.

   DROP TABLE test;
   DROP DATABASE etldemo;

Acessar dados de tabela larga

Conexões Spark SQL em um grupo de recursos ETL podem consultar dados do LindormTable usando recursos de computação elásticos. Instruções de Linguagem de Definição de Dados (DDL) — como CREATE TABLE ou DROP TABLE — não são suportadas para o LindormTable por meio desta conexão. Utilize-a apenas para consultas e computações.

Alterne para o catálogo de tabela larga antes de consultar:

SET CATALOG lindorm_table;

Se você já possui uma tabela larga, pule para as etapas de consulta. Caso contrário, conecte-se ao LindormTable e crie uma tabela de exemplo:

-- 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');

Na sessão lindorm-beeline, execute as etapas a seguir.

1. Altere a fonte de dados e selecione o banco de dados.

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

2. Consulte dados da tabela larga. Exemplo 1 — recuperar linhas:

   SELECT * FROM tb LIMIT 5;

   Resultado:

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

   Exemplo 2 — contar linhas:

   SELECT count(*) FROM tb;

   Resultado:

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