File tree Expand file tree Collapse file tree 2 files changed +30
-3
lines changed Expand file tree Collapse file tree 2 files changed +30
-3
lines changed Original file line number Diff line number Diff line change @@ -193,8 +193,17 @@ impl DisplayAs for LazyMemoryExec {
193193 )
194194 }
195195 DisplayFormatType :: TreeRender => {
196- // TODO: collect info
197- write ! ( f, "" )
196+ //TODO: remove batch_size, add one line per generator
197+ writeln ! (
198+ f,
199+ "batch_generators={}" ,
200+ self . batch_generators
201+ . iter( )
202+ . map( |g| g. read( ) . to_string( ) )
203+ . collect:: <Vec <String >>( )
204+ . join( ", " )
205+ ) ?;
206+ Ok ( ( ) )
198207 }
199208 }
200209 }
Original file line number Diff line number Diff line change @@ -725,7 +725,12 @@ physical_plan
72572532)└─────────────┬─────────────┘
72672633)┌─────────────┴─────────────┐
72772734)│ LazyMemoryExec │
728- 35)└───────────────────────────┘
728+ 35)│ -------------------- │
729+ 36)│ batch_generators: │
730+ 37)│ generate_series: start=1, │
731+ 38)│ end=1000, batch_size │
732+ 39)│ =8192 │
733+ 40)└───────────────────────────┘
729734
730735query TT
731736explain select
@@ -1641,3 +1646,16 @@ physical_plan
1641164608)│ format: memory │
1642164709)│ rows: 1 │
1643164810)└───────────────────────────┘
1649+
1650+ # Test explain tree for LazyMemoryExec
1651+ query TT
1652+ EXPLAIN SELECT * FROM generate_series(1, 100)
1653+ ----
1654+ physical_plan
1655+ 01)┌───────────────────────────┐
1656+ 02)│ LazyMemoryExec │
1657+ 03)│ -------------------- │
1658+ 04)│ batch_generators: │
1659+ 05)│ generate_series: start=1, │
1660+ 06)│ end=100, batch_size=8192 │
1661+ 07)└───────────────────────────┘
You can’t perform that action at this time.
0 commit comments