blob: 4485b36ac85b8a714f8072175f582d22891e7bc0 [file] [log] [blame]
buyingyic73348c2012-11-02 00:31:31 +00001write [%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|