| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 1 | write [%0->$$1, %0->$$4, %0->$$5, %0->$$7] |
| 2 | -- SINK_WRITE |UNPARTITIONED| |
| 3 | limit 4 |
| 4 | -- STREAM_LIMIT |UNPARTITIONED| |
| 5 | limit 4 |
| 6 | -- STREAM_LIMIT |UNPARTITIONED| |
| 7 | exchange |
| 8 | -- SORT_MERGE_EXCHANGE [$$4(ASC) ] |PARTITIONED| |
| 9 | limit 4 |
| buyingyi | 7ee9aac | 2013-07-16 17:21:26 -0700 | [diff] [blame^] | 10 | -- STREAM_LIMIT |PARTITIONED| |
| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 11 | exchange |
| buyingyi | 7ee9aac | 2013-07-16 17:21:26 -0700 | [diff] [blame^] | 12 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 13 | order (ASC, %0->$$4) |
| buyingyi | 7ee9aac | 2013-07-16 17:21:26 -0700 | [diff] [blame^] | 14 | -- STABLE_SORT [$$4(ASC)] |PARTITIONED| |
| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 15 | exchange |
| 16 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| buyingyi | ff52e13 | 2013-07-09 23:46:43 -0700 | [diff] [blame] | 17 | select (function-call: algebricks:lt, Args:[%0->$$4, 10000.0]) |
| buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 18 | -- STREAM_SELECT |PARTITIONED| |
| 19 | exchange |
| 20 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 21 | data-scan [$$1, $$4, $$5, $$7]<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7, $$8, $$9] <- default.orders |
| 22 | -- DATASOURCE_SCAN |PARTITIONED| |
| 23 | exchange |
| 24 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 25 | empty-tuple-source |
| 26 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |