@@ -1551,24 +1551,26 @@ physical_plan
1551155109)┌─────────────┴─────────────┐
1552155210)│ FilterExec │
1553155311)│ -------------------- │
1554- 12)│ predicate: │
1555- 13)│ date = 2006-01-02 │
1556- 14)└─────────────┬─────────────┘
1557- 15)┌─────────────┴─────────────┐
1558- 16)│ RepartitionExec │
1559- 17)│ -------------------- │
1560- 18)│ partition_count(in->out): │
1561- 19)│ 1 -> 4 │
1562- 20)│ │
1563- 21)│ partitioning_scheme: │
1564- 22)│ RoundRobinBatch(4) │
1565- 23)└─────────────┬─────────────┘
1566- 24)┌─────────────┴─────────────┐
1567- 25)│ StreamingTableExec │
1568- 26)│ -------------------- │
1569- 27)│ infinite: true │
1570- 28)│ limit: None │
1571- 29)└───────────────────────────┘
1554+ 12)│ fetch: 5 │
1555+ 13)│ │
1556+ 14)│ predicate: │
1557+ 15)│ date = 2006-01-02 │
1558+ 16)└─────────────┬─────────────┘
1559+ 17)┌─────────────┴─────────────┐
1560+ 18)│ RepartitionExec │
1561+ 19)│ -------------------- │
1562+ 20)│ partition_count(in->out): │
1563+ 21)│ 1 -> 4 │
1564+ 22)│ │
1565+ 23)│ partitioning_scheme: │
1566+ 24)│ RoundRobinBatch(4) │
1567+ 25)└─────────────┬─────────────┘
1568+ 26)┌─────────────┴─────────────┐
1569+ 27)│ StreamingTableExec │
1570+ 28)│ -------------------- │
1571+ 29)│ infinite: true │
1572+ 30)│ limit: None │
1573+ 31)└───────────────────────────┘
15721574
15731575
15741576
@@ -1775,15 +1777,16 @@ physical_plan
1775177740)┌─────────────┴─────────────┐
1776177841)│ FilterExec │
1777177942)│ -------------------- │
1778- 43)│ predicate: a > 3 │
1779- 44)└─────────────┬─────────────┘
1780- 45)┌─────────────┴─────────────┐
1781- 46)│ DataSourceExec │
1782- 47)│ -------------------- │
1783- 48)│ bytes: 160 │
1784- 49)│ format: memory │
1785- 50)│ rows: 1 │
1786- 51)└───────────────────────────┘
1780+ 43)│ fetch: 9 │
1781+ 44)│ predicate: a > 3 │
1782+ 45)└─────────────┬─────────────┘
1783+ 46)┌─────────────┴─────────────┐
1784+ 47)│ DataSourceExec │
1785+ 48)│ -------------------- │
1786+ 49)│ bytes: 160 │
1787+ 50)│ format: memory │
1788+ 51)│ rows: 1 │
1789+ 52)└───────────────────────────┘
17871790
17881791# clean up
17891792statement ok
@@ -1815,23 +1818,24 @@ physical_plan
1815181806)┌─────────────┴─────────────┐
1816181907)│ FilterExec │
1817182008)│ -------------------- │
1818- 09)│ predicate: c3 > 0 │
1819- 10)└─────────────┬─────────────┘
1820- 11)┌─────────────┴─────────────┐
1821- 12)│ RepartitionExec │
1822- 13)│ -------------------- │
1823- 14)│ partition_count(in->out): │
1824- 15)│ 1 -> 4 │
1825- 16)│ │
1826- 17)│ partitioning_scheme: │
1827- 18)│ RoundRobinBatch(4) │
1828- 19)└─────────────┬─────────────┘
1829- 20)┌─────────────┴─────────────┐
1830- 21)│ StreamingTableExec │
1831- 22)│ -------------------- │
1832- 23)│ infinite: true │
1833- 24)│ limit: None │
1834- 25)└───────────────────────────┘
1821+ 09)│ fetch: 5 │
1822+ 10)│ predicate: c3 > 0 │
1823+ 11)└─────────────┬─────────────┘
1824+ 12)┌─────────────┴─────────────┐
1825+ 13)│ RepartitionExec │
1826+ 14)│ -------------------- │
1827+ 15)│ partition_count(in->out): │
1828+ 16)│ 1 -> 4 │
1829+ 17)│ │
1830+ 18)│ partitioning_scheme: │
1831+ 19)│ RoundRobinBatch(4) │
1832+ 20)└─────────────┬─────────────┘
1833+ 21)┌─────────────┴─────────────┐
1834+ 22)│ StreamingTableExec │
1835+ 23)│ -------------------- │
1836+ 24)│ infinite: true │
1837+ 25)│ limit: None │
1838+ 26)└───────────────────────────┘
18351839
18361840# Test explain tree for PlaceholderRowExec
18371841query TT
0 commit comments