Skip to content

Commit 3c2ba22

Browse files
authored
[doc] Remove 'testcatalog'. 'testdb' from the "Flink Reads" page (#1234)
1 parent a6c2d39 commit 3c2ba22

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

website/docs/engine-flink/reads.md

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -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,19 +82,19 @@ 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:**
9494

9595
```
9696
== Optimized Execution Plan ==
97-
TableSourceScan(table=[[testcatalog, testdb, log_table, project=[c_name]]], fields=[c_name])
97+
TableSourceScan(table=[[fluss_catalog, fluss, log_table, project=[c_name]]], fields=[c_name])
9898
```
9999

100100
This confirms that only the `c_name` column is being read from storage.
@@ -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

134134
Fluss source will scan only the partitions where `c_nationkey = 'US'`.
@@ -145,14 +145,14 @@ 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:**
152152

153153
```text
154154
== Optimized Execution Plan ==
155-
TableSourceScan(table=[[testcatalog, testdb, log_partitioned_table, filter=[=(c_nationkey, _UTF-16LE'US':VARCHAR(2147483647) CHARACTER SET "UTF-16LE")]]], fields=[c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment, dt])
155+
TableSourceScan(table=[[fluss_catalog, fluss, log_partitioned_table, filter=[=(c_nationkey, _UTF-16LE'US':VARCHAR(2147483647) CHARACTER SET "UTF-16LE")]]], fields=[c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment, dt])
156156
```
157157

158158
This confirms that only partitions matching `c_nationkey = 'US'` will be scanned.

0 commit comments

Comments
 (0)