Skip to content

Commit 0384b09

Browse files
committed
minor update
1 parent 2e34b92 commit 0384b09

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

website/docs/engine-flink/reads.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ EXPLAIN SELECT `c_name` FROM `log_table`;
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.
@@ -152,7 +152,7 @@ EXPLAIN SELECT * FROM `log_partitioned_table` WHERE `c_nationkey` = 'US';
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)