@@ -42,14 +42,34 @@ suite("delta_row") {
42
42
sql " set global enable_auto_analyze=false;"
43
43
44
44
sql " insert into t values (10, 'c');"
45
- explain {
46
- sql " physical plan select * from t where k > 6"
47
- contains(" stats=0.5," )
48
- contains(" stats=5(1)" )
49
- notContains(" stats=0," )
50
- notContains(" stats=4 " )
45
+ def result = sql """ explain physical plan select * from t where k > 6"""
46
+ logger. info(" result:" + result)
47
+ def stringResult = " "
48
+ for (int i = 0 ; i < result. size(); i++ ) {
49
+ stringResult + = result[i]
50
+ }
51
+ logger. info(" stringResult:" + stringResult)
52
+ if (stringResult. contains(" stats=5(1)" )) {
53
+ logger. info(" rows not reported, test analyze rows + delta rows" )
54
+ assertTrue (stringResult. contains(" stats=0.5," ))
55
+ assertFalse (stringResult. contains(" stats=0," ))
56
+ assertFalse (stringResult. contains(" stats=4 " ))
57
+ } else {
58
+ logger. info(" rows reported, test use reported rows." )
59
+ result = sql """ show index stats t t"""
60
+ logger. info(" index stats: " + result)
61
+ assertEquals (1 , result. size())
62
+ assertNotEquals(" -1" , result[0 ][4 ])
63
+ }
64
+ // explain {
65
+ // sql "physical plan select * from t where k > 6"
66
+ // contains("stats=0.5,")
67
+ // contains("stats=5(1)")
68
+ // notContains("stats=0,")
69
+ // notContains("stats=4 ")
70
+ // cost = 5.00002
51
71
// PhysicalResultSink[75] ( outputExprs=[k#0, v#1] )
52
72
// +--PhysicalFilter[72]@1 ( stats=0.5, predicates=(k#0 > 6) )
53
73
// +--PhysicalOlapScan[t]@0 ( stats=5(1) )
54
- }
55
- }
74
+ }
75
+
0 commit comments