@@ -68,7 +68,7 @@ Benchmark results show that column pruning can reach 10x read performance improv
6868
6969** 1. Create a table**
7070``` sql title="Flink SQL"
71- CREATE TABLE `testcatalog `. ` testdb ` . ` log_table` (
71+ CREATE TABLE `log_table ` (
7272 ` c_custkey` INT NOT NULL ,
7373 ` c_name` STRING NOT NULL ,
7474 ` c_address` STRING NOT NULL ,
@@ -82,12 +82,12 @@ CREATE TABLE `testcatalog`.`testdb`.`log_table` (
8282
8383** 2. Query a single column:**
8484``` sql title="Flink SQL"
85- SELECT ` c_name` FROM ` testcatalog ` . ` testdb ` . ` log_table` ;
85+ SELECT ` c_name` FROM ` log_table` ;
8686```
8787
8888** 3. Verify with ` EXPLAIN ` :**
8989``` sql title="Flink SQL"
90- EXPLAIN SELECT ` c_name` FROM ` testcatalog ` . ` testdb ` . ` log_table` ;
90+ EXPLAIN SELECT ` c_name` FROM ` log_table` ;
9191```
9292
9393** Output:**
@@ -113,7 +113,7 @@ The partition pruning also supports dynamically pruning new created partitions d
113113
114114** 1. Create a partitioned table:**
115115``` sql title="Flink SQL"
116- CREATE TABLE `testcatalog `. ` testdb ` . ` log_partitioned_table` (
116+ CREATE TABLE `log_partitioned_table ` (
117117 ` c_custkey` INT NOT NULL ,
118118 ` c_name` STRING NOT NULL ,
119119 ` c_address` STRING NOT NULL ,
@@ -128,7 +128,7 @@ CREATE TABLE `testcatalog`.`testdb`.`log_partitioned_table` (
128128
129129** 2. Query with partition filter:**
130130``` sql title="Flink SQL"
131- SELECT * FROM ` testcatalog ` . ` testdb ` . ` log_partitioned_table` WHERE ` c_nationkey` = ' US' ;
131+ SELECT * FROM ` log_partitioned_table` WHERE ` c_nationkey` = ' US' ;
132132```
133133
134134Fluss source will scan only the partitions where ` c_nationkey = 'US' ` .
@@ -145,7 +145,7 @@ As new partitions like `US,2025-06-15`, `China,2025-06-15` are created, partitio
145145** 3. Verify with ` EXPLAIN ` :**
146146
147147``` sql title="Flink SQL"
148- EXPLAIN SELECT * FROM ` testcatalog ` . ` testdb ` . ` log_partitioned_table` WHERE ` c_nationkey` = ' US' ;
148+ EXPLAIN SELECT * FROM ` log_partitioned_table` WHERE ` c_nationkey` = ' US' ;
149149```
150150
151151** Output:**
0 commit comments