mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-08 22:32:55 +00:00
179c8c716c
* feat: define region scanner * feat: single partition scanner * feat: use single partition scanner * feat: implement ExecutionPlan wip * feat: mito engine returns single partition scanner * feat: implement DisplayAs for region server * feat: dummy table provider use handle_partitioned_query() * test: update sqlness test * feat: table provider use ReadFromRegion * refactor: remove StreamScanAdapter * chore: update lock * style: fix clippy * refactor: remove handle_query from the RegionEngine trait * chore: address CR comments * refactor: rename methods * refactor: rename ReadFromRegion to RegionScanExec
57 lines
3.3 KiB
Plaintext
57 lines
3.3 KiB
Plaintext
explain select * from numbers;
|
|
|
|
+---------------+-----------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+-----------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false] |
|
|
| physical_plan | SinglePartitionScanner: <SendableRecordBatchStream> |
|
|
| | |
|
|
+---------------+-----------------------------------------------------+
|
|
|
|
explain select * from numbers order by number desc;
|
|
|
|
+---------------+-------------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+-------------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false] |
|
|
| physical_plan | SortExec: expr=[number@0 DESC] |
|
|
| | SinglePartitionScanner: <SendableRecordBatchStream> |
|
|
| | |
|
|
+---------------+-------------------------------------------------------+
|
|
|
|
explain select * from numbers order by number asc;
|
|
|
|
+---------------+-------------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+-------------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false] |
|
|
| physical_plan | SortExec: expr=[number@0 ASC NULLS LAST] |
|
|
| | SinglePartitionScanner: <SendableRecordBatchStream> |
|
|
| | |
|
|
+---------------+-------------------------------------------------------+
|
|
|
|
explain select * from numbers order by number desc limit 10;
|
|
|
|
+---------------+---------------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+---------------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false] |
|
|
| physical_plan | GlobalLimitExec: skip=0, fetch=10 |
|
|
| | SortExec: TopK(fetch=10), expr=[number@0 DESC] |
|
|
| | SinglePartitionScanner: <SendableRecordBatchStream> |
|
|
| | |
|
|
+---------------+---------------------------------------------------------+
|
|
|
|
explain select * from numbers order by number asc limit 10;
|
|
|
|
+---------------+------------------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+------------------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false] |
|
|
| physical_plan | GlobalLimitExec: skip=0, fetch=10 |
|
|
| | SortExec: TopK(fetch=10), expr=[number@0 ASC NULLS LAST] |
|
|
| | SinglePartitionScanner: <SendableRecordBatchStream> |
|
|
| | |
|
|
+---------------+------------------------------------------------------------+
|
|
|