SQL Type | Description | Example |
SHOW Statement | Query metadata information | SHOW CATALOGS;,SHOW DATABASES;,SHOW TABLES; |
DESCRIBE Statement | View the table structure. | DESCRIBE table_name; |
SELECT queries | Data queries | SELECT * FROM source_table; |
CREATE Statement | Create temporary tables/views | CREATE TEMPORARY TABLE ... WITH (...); |
INSERT | Data writes (by submitting a Flink job) | INSERT INTO sink_table SELECT ... FROM source_table; |
SET Statement | Set execution parameters | SET 'execution.runtime-mode' = 'streaming'; |
EXPLAIN Statement | View the execution plan | EXPLAIN SELECT ...; |
USE Statement | Switch the Catalog/Database | USE CATALOG my_catalog; |
-- View the current Catalog and DatabaseSHOW CURRENT CATALOG;SHOW CURRENT DATABASE;-- View all CatalogsSHOW CATALOGS;-- Simple QuerySELECT 1;SELECT CURRENT_TIMESTAMP AS ts, UUID() AS u;SELECT CAST('2026-01-01' AS DATE) AS d;-- Multi-Column QuerySELECT 1 AS id, 'hello' AS name, 3.14 AS pi;
-- Create a temporary table (Data Generator)CREATE TEMPORARY TABLE datagen_source (id INT,name STRING) WITH ('connector' = 'datagen','rows-per-second' = '1','number-of-rows' = '10');-- Query the temporary tableSELECT * FROM datagen_source;-- Aggregate QuerySELECT COUNT(*) AS cnt, AVG(id) AS avg_id FROM datagen_source;
-- Switch to the Paimon CatalogUSE CATALOG my_paimon_catalog;-- View databases and tablesSHOW DATABASES;USE my_database;SHOW TABLES;-- Query the Paimon tableSELECT * FROM my_table LIMIT 100;SELECT COUNT(*) FROM my_table;
-- Query with VALUES clause (Data Construction)SELECT * FROM (VALUES (1, 'a'), (2, 'b'), (3, 'c')) AS t(id, name);-- Filter with WHERE clauseSELECT x, x*x AS sq FROM (VALUES (1),(2),(3),(4),(5)) AS t(x) WHERE x > 2;-- Aggregate with GROUP BYSELECT grp, COUNT(*) AS cnt, SUM(val) AS totalFROM (VALUES ('a',1), ('a',2), ('b',10), ('b',20)) AS t(grp, val)GROUP BY grp;
-- View the current configurationSET;-- View the specified configurationSET 'parallelism.default';-- Switch the execution modeSET 'execution.runtime-mode' = 'streaming';SET 'execution.runtime-mode' = 'batch';-- Set the time zoneSET 'table.local-time-zone' = 'Asia/Shanghai';
フィードバック