buyingyi | c73348c | 2012-11-02 00:31:31 +0000 | [diff] [blame] | 1 | write [%0->$$8, %0->$$3, %0->$$4, %0->$$2] |
| 2 | -- SINK_WRITE |PARTITIONED| |
| 3 | project ([$$8, $$3, $$4, $$2]) |
| 4 | -- STREAM_PROJECT |PARTITIONED| |
| 5 | assign [$$8] <- [function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[2, %0->$$1]] |
| 6 | -- ASSIGN |PARTITIONED| |
| 7 | select (function-call: algebricks:lt, Args:[function-call: hive:org.apache.hadoop.hive.ql.udf.UDFOPMultiply, Args:[%0->$$1, 2], 20]) |
| 8 | -- STREAM_SELECT |PARTITIONED| |
| 9 | exchange |
| 10 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 11 | data-scan []<-[$$1, $$2, $$3, $$4, $$5, $$6, $$7] <- default.supplier |
| 12 | -- DATASOURCE_SCAN |PARTITIONED| |
| 13 | exchange |
| 14 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
| 15 | empty-tuple-source |
| 16 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |