File tree Expand file tree Collapse file tree 2 files changed +18
-8
lines changed
src/query/service/src/interpreters
tests/sqllogictests/suites/tpch Expand file tree Collapse file tree 2 files changed +18
-8
lines changed Original file line number Diff line number Diff line change @@ -132,6 +132,16 @@ impl Interpreter for AnalyzeTableInterpreter {
132
132
return Ok ( PipelineBuildResult :: create ( ) ) ;
133
133
}
134
134
135
+ let table_statistics = table
136
+ . read_table_snapshot_statistics ( Some ( & snapshot) )
137
+ . await ?;
138
+ if let Some ( table_statistics) = & table_statistics {
139
+ let prev_snapshot_id = snapshot. prev_snapshot_id . map ( |( id, _) | id) ;
140
+ if Some ( table_statistics. snapshot_id ) == prev_snapshot_id {
141
+ return Ok ( PipelineBuildResult :: create ( ) ) ;
142
+ }
143
+ }
144
+
135
145
let mut parts = Vec :: with_capacity ( snapshot. segments . len ( ) ) ;
136
146
for ( idx, segment_location) in snapshot. segments . iter ( ) . enumerate ( ) {
137
147
parts. push ( FuseLazyPartInfo :: create ( idx, segment_location. clone ( ) ) ) ;
Original file line number Diff line number Diff line change @@ -312,21 +312,21 @@ HashJoin: INNER
312
312
├── Build
313
313
│ └── HashJoin: INNER
314
314
│ ├── Build
315
- │ │ └── Scan: default.tpch_test.nation (#4) (read rows: 25)
315
+ │ │ └── HashJoin: INNER
316
+ │ │ ├── Build
317
+ │ │ │ └── Scan: default.tpch_test.nation (#5) (read rows: 25)
318
+ │ │ └── Probe
319
+ │ │ └── Scan: default.tpch_test.customer (#3) (read rows: 150000)
316
320
│ └── Probe
317
- │ └── Scan: default.tpch_test.supplier (#0 ) (read rows: 10000 )
321
+ │ └── Scan: default.tpch_test.orders (#2 ) (read rows: 1500000 )
318
322
└── Probe
319
323
└── HashJoin: INNER
320
324
├── Build
321
325
│ └── HashJoin: INNER
322
326
│ ├── Build
323
- │ │ └── HashJoin: INNER
324
- │ │ ├── Build
325
- │ │ │ └── Scan: default.tpch_test.nation (#5) (read rows: 25)
326
- │ │ └── Probe
327
- │ │ └── Scan: default.tpch_test.customer (#3) (read rows: 150000)
327
+ │ │ └── Scan: default.tpch_test.nation (#4) (read rows: 25)
328
328
│ └── Probe
329
- │ └── Scan: default.tpch_test.orders (#2 ) (read rows: 1500000 )
329
+ │ └── Scan: default.tpch_test.supplier (#0 ) (read rows: 10000 )
330
330
└── Probe
331
331
└── Scan: default.tpch_test.lineitem (#1) (read rows: 6001215)
332
332
You can’t perform that action at this time.
0 commit comments