@@ -28,7 +28,7 @@ async fn test_select_interpreter() -> Result<()> {
28
28
let query = "select number from numbers_mt(10)" ;
29
29
let ( plan, _, _) = planner. plan_sql ( query) . await ?;
30
30
let executor = InterpreterFactoryV2 :: get ( ctx. clone ( ) , & plan) . await ?;
31
- assert_eq ! ( executor. name( ) , "SelectInterpreter " ) ;
31
+ assert_eq ! ( executor. name( ) , "SelectInterpreterV2 " ) ;
32
32
33
33
let stream = executor. execute ( ctx. clone ( ) ) . await ?;
34
34
let result = stream. try_collect :: < Vec < _ > > ( ) . await ?;
@@ -58,19 +58,19 @@ async fn test_select_interpreter() -> Result<()> {
58
58
let query = "select 1 + 1, 2 + 2, 3 * 3, 4 * 4" ;
59
59
let ( plan, _, _) = planner. plan_sql ( query) . await ?;
60
60
let executor = InterpreterFactoryV2 :: get ( ctx. clone ( ) , & plan) . await ?;
61
- assert_eq ! ( executor. name( ) , "SelectInterpreter " ) ;
61
+ assert_eq ! ( executor. name( ) , "SelectInterpreterV2 " ) ;
62
62
63
63
let stream = executor. execute ( ctx. clone ( ) ) . await ?;
64
64
let result = stream. try_collect :: < Vec < _ > > ( ) . await ?;
65
65
let block = & result[ 0 ] ;
66
66
assert_eq ! ( block. num_columns( ) , 4 ) ;
67
67
68
68
let expected = vec ! [
69
- "+--------- +--------- +---------+-- -------+" ,
70
- "| ( 1 + 1) | ( 2 + 2) | ( 3 * 3) | ( 4 * 4) |" ,
71
- "+--------- +--------- +---------+-- -------+" ,
72
- "| 2 | 4 | 9 | 16 |" ,
73
- "+--------- +--------- +---------+-- -------+" ,
69
+ "+-------+-------+-------+ -------+" ,
70
+ "| 1 + 1 | 2 + 2 | 3 * 3 | 4 * 4 |" ,
71
+ "+-------+-------+-------+ -------+" ,
72
+ "| 2 | 4 | 9 | 16 |" ,
73
+ "+-------+-------+-------+ -------+" ,
74
74
] ;
75
75
common_datablocks:: assert_blocks_sorted_eq ( expected, result. as_slice ( ) ) ;
76
76
}
0 commit comments