Repository: hive Updated Branches: refs/heads/master 3db7227fc -> be9735e10
http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out b/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out index 078c07c..1d75d04 100644 --- a/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out +++ b/ql/src/test/results/clientpositive/tez/vector_struct_in.q.out @@ -51,14 +51,14 @@ struct('ten','1') ) POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1"] - Filter Operator [FIL_4] - predicate:(struct(id,lineid)) IN (const struct('two','3'), const struct('three','1'), const struct('one','1'), const struct('five','2'), const struct('six','1'), const struct('eight','1'), const struct('seven','1'), const struct('nine','1'), const struct('ten','1')) (type: boolean) - TableScan [TS_0] - alias:test_1 + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1"] + Filter Operator [FIL_4] + predicate:(struct(id,lineid)) IN (const struct('two','3'), const struct('three','1'), const struct('one','1'), const struct('five','2'), const struct('six','1'), const struct('eight','1'), const struct('seven','1'), const struct('nine','1'), const struct('ten','1')) + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select * from test_1 where struct(`id`, `lineid`) IN ( @@ -121,12 +121,12 @@ struct('ten','1') ) as b from test_1 POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2"] - TableScan [TS_0] - alias:test_1 + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2"] + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`) IN ( @@ -209,14 +209,14 @@ struct(10,1) ) POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1"] - Filter Operator [FIL_4] - predicate:(struct(id,lineid)) IN (const struct(2,3), const struct(3,1), const struct(1,1), const struct(5,2), const struct(6,1), const struct(8,1), const struct(7,1), const struct(9,1), const struct(10,1)) (type: boolean) - TableScan [TS_0] - alias:test_2 + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1"] + Filter Operator [FIL_4] + predicate:(struct(id,lineid)) IN (const struct(2,3), const struct(3,1), const struct(1,1), const struct(5,2), const struct(6,1), const struct(8,1), const struct(7,1), const struct(9,1), const struct(10,1)) + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select * from test_2 where struct(`id`, `lineid`) IN ( @@ -279,12 +279,12 @@ struct(10,1) ) as b from test_2 POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2"] - TableScan [TS_0] - alias:test_2 + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2"] + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`) IN ( @@ -367,14 +367,14 @@ struct('ten',1) ) POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1"] - Filter Operator [FIL_4] - predicate:(struct(id,lineid)) IN (const struct('two',3), const struct('three',1), const struct('one',1), const struct('five',2), const struct('six',1), const struct('eight',1), const struct('seven',1), const struct('nine',1), const struct('ten',1)) (type: boolean) - TableScan [TS_0] - alias:test_3 + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1"] + Filter Operator [FIL_4] + predicate:(struct(id,lineid)) IN (const struct('two',3), const struct('three',1), const struct('one',1), const struct('five',2), const struct('six',1), const struct('eight',1), const struct('seven',1), const struct('nine',1), const struct('ten',1)) + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select * from test_3 where struct(`id`, `lineid`) IN ( @@ -437,12 +437,12 @@ struct('ten',1) ) as b from test_3 POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2"] - TableScan [TS_0] - alias:test_3 + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2"] + TableScan [TS_0] + Output:["id","lineid"] PREHOOK: query: select `id`, `lineid`, struct(`id`, `lineid`) IN ( @@ -528,14 +528,14 @@ struct(3L, "b", 1.5) ) POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1","_col2"] - Filter Operator [FIL_4] - predicate:(struct(my_bigint,my_string,my_double)) IN (const struct(1,'a',1.5), const struct(1,'b',-0.5), const struct(3,'b',1.5), const struct(1,'d',1.5), const struct(1,'c',1.5), const struct(1,'b',2.5), const struct(1,'b',0.5), const struct(5,'b',1.5), const struct(1,'a',0.5), const struct(3,'b',1.5)) (type: boolean) - TableScan [TS_0] - alias:test_4 + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_4] + predicate:(struct(my_bigint,my_string,my_double)) IN (const struct(1,'a',1.5), const struct(1,'b',-0.5), const struct(3,'b',1.5), const struct(1,'d',1.5), const struct(1,'c',1.5), const struct(1,'b',2.5), const struct(1,'b',0.5), const struct(5,'b',1.5), const struct(1,'a',0.5), const struct(3,'b',1.5)) + TableScan [TS_0] + Output:["my_bigint","my_string","my_double"] PREHOOK: query: select * from test_4 where struct(`my_bigint`, `my_string`, `my_double`) IN ( @@ -601,12 +601,12 @@ struct(3L, "b", 1.5) ) as b from test_4 POSTHOOK: type: QUERY Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2","_col3"] - TableScan [TS_0] - alias:test_4 + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2","_col3"] + TableScan [TS_0] + Output:["my_bigint","my_string","my_double"] PREHOOK: query: select `my_bigint`, `my_string`, `my_double`, struct(`my_bigint`, `my_string`, `my_double`) IN ( http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out b/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out index 0cb2270..8355381 100644 --- a/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out +++ b/ql/src/test/results/clientpositive/tez/vectorized_parquet_types.q.out @@ -130,12 +130,12 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] - TableScan [TS_0] - alias:parquet_types + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] + TableScan [TS_0] + Output:["cint","ctinyint","csmallint","cfloat","cdouble","cstring1","t","cchar","cvarchar","cbinary","cdecimal"] PREHOOK: query: SELECT cint, ctinyint, csmallint, cfloat, cdouble, cstring1, t, cchar, cvarchar, hex(cbinary), cdecimal FROM parquet_types @@ -178,12 +178,12 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_1] - outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5"] - TableScan [TS_0] - alias:parquet_types + Fetch Operator + limit:-1 + Select Operator [SEL_1] + Output:["_col0","_col1","_col2","_col3","_col4","_col5"] + TableScan [TS_0] + Output:["cchar","cvarchar","cdecimal"] PREHOOK: query: SELECT cchar, LENGTH(cchar), cvarchar, LENGTH(cvarchar), cdecimal, SIGN(cdecimal) FROM parquet_types PREHOOK: type: QUERY @@ -246,46 +246,26 @@ Reducer 2 <- Map 1 (SIMPLE_EDGE) Reducer 3 <- Reducer 2 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 3 vectorized - File Output Operator [FS_10] - compressed:false - Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Select Operator [OP_9] - | outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] - | Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 2 [SIMPLE_EDGE] - Reduce Output Operator [RS_6] - key expressions:_col0 (type: tinyint) - sort order:+ - Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: int), _col2 (type: smallint), _col3 (type: bigint), _col4 (type: double), _col5 (type: double), _col6 (type: decimal(4,2)) - Group By Operator [GBY_4] - | aggregations:["max(VALUE._col0)","min(VALUE._col1)","count(VALUE._col2)","avg(VALUE._col3)","stddev_pop(VALUE._col4)","max(VALUE._col5)"] - | keys:KEY._col0 (type: tinyint) - | outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] - | Statistics:Num rows: 11 Data size: 121 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - Reduce Output Operator [RS_3] - key expressions:_col0 (type: tinyint) - Map-reduce partition columns:_col0 (type: tinyint) - sort order:+ - Statistics:Num rows: 22 Data size: 242 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: int), _col2 (type: smallint), _col3 (type: bigint), _col4 (type: struct<count:bigint,sum:double,input:float>), _col5 (type: struct<count:bigint,sum:double,variance:double>), _col6 (type: decimal(4,2)) - Group By Operator [GBY_2] - aggregations:["max(cint)","min(csmallint)","count(cstring1)","avg(cfloat)","stddev_pop(cdouble)","max(cdecimal)"] - keys:ctinyint (type: tinyint) - outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] - Statistics:Num rows: 22 Data size: 242 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_1] - outputColumnNames:["ctinyint","cint","csmallint","cstring1","cfloat","cdouble","cdecimal"] - Statistics:Num rows: 22 Data size: 242 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_0] - alias:parquet_types - Statistics:Num rows: 22 Data size: 242 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 3 vectorized + File Output Operator [FS_10] + Select Operator [OP_9] (rows=11 width=11) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"] + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_6] + Group By Operator [GBY_4] (rows=11 width=11) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["max(VALUE._col0)","min(VALUE._col1)","count(VALUE._col2)","avg(VALUE._col3)","stddev_pop(VALUE._col4)","max(VALUE._col5)"],keys:KEY._col0 + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_3] + PartitionCols:_col0 + Group By Operator [GBY_2] (rows=22 width=11) + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6"],aggregations:["max(cint)","min(csmallint)","count(cstring1)","avg(cfloat)","stddev_pop(cdouble)","max(cdecimal)"],keys:ctinyint + Select Operator [SEL_1] (rows=22 width=11) + Output:["ctinyint","cint","csmallint","cstring1","cfloat","cdouble","cdecimal"] + TableScan [TS_0] (rows=22 width=11) + default@parquet_types,parquet_types,Tbl:COMPLETE,Col:NONE,Output:["cint","ctinyint","csmallint","cfloat","cdouble","cstring1","cdecimal"] PREHOOK: query: SELECT ctinyint, MAX(cint), http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out b/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out index 8f9b305..d8f21e0 100644 --- a/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out +++ b/ql/src/test/results/clientpositive/tez/vectorized_timestamp_ints_casts.q.out @@ -37,14 +37,14 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] - Filter Operator [FIL_4] - predicate:((cbigint % 250) = 0) (type: boolean) - TableScan [TS_0] - alias:alltypesorc + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] + Filter Operator [FIL_4] + predicate:((cbigint % 250) = 0) + TableScan [TS_0] + Output:["ctinyint","csmallint","cint","cbigint","cfloat","cdouble","cstring1","ctimestamp1","cboolean1"] PREHOOK: query: select -- to timestamp @@ -149,14 +149,14 @@ POSTHOOK: type: QUERY Plan optimized by CBO. Stage-0 - Fetch Operator - limit:-1 - Select Operator [SEL_2] - outputColumnNames:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] - Filter Operator [FIL_4] - predicate:((cbigint % 250) = 0) (type: boolean) - TableScan [TS_0] - alias:alltypesorc + Fetch Operator + limit:-1 + Select Operator [SEL_2] + Output:["_col0","_col1","_col2","_col3","_col4","_col5","_col6","_col7","_col8","_col9","_col10"] + Filter Operator [FIL_4] + predicate:((cbigint % 250) = 0) + TableScan [TS_0] + Output:["ctinyint","csmallint","cint","cbigint","cfloat","cdouble","cstring1","ctimestamp1","cboolean1"] PREHOOK: query: select -- to timestamp http://git-wip-us.apache.org/repos/asf/hive/blob/be9735e1/ql/src/test/results/clientpositive/tez/windowing_gby.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/windowing_gby.q.out b/ql/src/test/results/clientpositive/tez/windowing_gby.q.out index 72d1f14..2af3e58 100644 --- a/ql/src/test/results/clientpositive/tez/windowing_gby.q.out +++ b/ql/src/test/results/clientpositive/tez/windowing_gby.q.out @@ -18,88 +18,49 @@ Reducer 3 <- Reducer 2 (SIMPLE_EDGE) Reducer 4 <- Reducer 3 (SIMPLE_EDGE) Stage-0 - Fetch Operator - limit:-1 - Stage-1 - Reducer 4 - File Output Operator [FS_19] - compressed:false - Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - table:{"input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat","serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"} - Select Operator [SEL_17] - outputColumnNames:["_col0"] - Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - PTF Operator [PTF_16] - Function definitions:[{"Input definition":{"type:":"WINDOWING"}},{"name:":"windowingtablefunction","order by:":"(UDFToDouble(_col1) / UDFToDouble(_col2))","partition by:":"0"}] - Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_15] - | outputColumnNames:["_col1","_col2"] - | Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 3 [SIMPLE_EDGE] - Reduce Output Operator [RS_14] - key expressions:0 (type: int), (UDFToDouble(_col1) / UDFToDouble(_col2)) (type: double) - Map-reduce partition columns:0 (type: int) - sort order:++ - Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: bigint), _col2 (type: bigint) - Select Operator [SEL_13] - outputColumnNames:["_col1","_col2"] - Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - Group By Operator [GBY_12] - | aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"] - | keys:KEY._col0 (type: boolean) - | outputColumnNames:["_col0","_col1","_col2"] - | Statistics:Num rows: 6758 Data size: 1453080 Basic stats: COMPLETE Column stats: NONE - |<-Reducer 2 [SIMPLE_EDGE] - Reduce Output Operator [RS_11] - key expressions:_col0 (type: boolean) - Map-reduce partition columns:_col0 (type: boolean) - sort order:+ - Statistics:Num rows: 13516 Data size: 2906160 Basic stats: COMPLETE Column stats: NONE - value expressions:_col1 (type: bigint), _col2 (type: bigint) - Group By Operator [GBY_10] - aggregations:["sum(_col3)","sum(_col1)"] - keys:_col2 (type: boolean) - outputColumnNames:["_col0","_col1","_col2"] - Statistics:Num rows: 13516 Data size: 2906160 Basic stats: COMPLETE Column stats: NONE - Select Operator [SEL_9] - outputColumnNames:["_col2","_col3","_col1"] - Statistics:Num rows: 13516 Data size: 2906160 Basic stats: COMPLETE Column stats: NONE - Merge Join Operator [MERGEJOIN_24] - | condition map:[{"":"Inner Join 0 to 1"}] - | keys:{"0":"_col0 (type: string)","1":"_col1 (type: string)"} - | outputColumnNames:["_col1","_col2","_col3"] - | Statistics:Num rows: 13516 Data size: 2906160 Basic stats: COMPLETE Column stats: NONE - |<-Map 1 [SIMPLE_EDGE] - | Reduce Output Operator [RS_6] - | key expressions:_col0 (type: string) - | Map-reduce partition columns:_col0 (type: string) - | sort order:+ - | Statistics:Num rows: 20 Data size: 262 Basic stats: COMPLETE Column stats: NONE - | value expressions:_col1 (type: int), _col2 (type: boolean) - | Select Operator [SEL_2] - | outputColumnNames:["_col0","_col1","_col2"] - | Statistics:Num rows: 20 Data size: 262 Basic stats: COMPLETE Column stats: NONE - | Filter Operator [FIL_22] - | predicate:value is not null (type: boolean) - | Statistics:Num rows: 20 Data size: 262 Basic stats: COMPLETE Column stats: NONE - | TableScan [TS_0] - | alias:ws - | Statistics:Num rows: 20 Data size: 262 Basic stats: COMPLETE Column stats: NONE - |<-Map 5 [SIMPLE_EDGE] - Reduce Output Operator [RS_7] - key expressions:_col1 (type: string) - Map-reduce partition columns:_col1 (type: string) - sort order:+ - Statistics:Num rows: 12288 Data size: 2641964 Basic stats: COMPLETE Column stats: NONE - value expressions:_col0 (type: int) - Select Operator [SEL_5] - outputColumnNames:["_col0","_col1"] - Statistics:Num rows: 12288 Data size: 2641964 Basic stats: COMPLETE Column stats: NONE - Filter Operator [FIL_23] - predicate:cstring1 is not null (type: boolean) - Statistics:Num rows: 12288 Data size: 2641964 Basic stats: COMPLETE Column stats: NONE - TableScan [TS_3] - alias:wr - Statistics:Num rows: 12288 Data size: 2641964 Basic stats: COMPLETE Column stats: NONE + Fetch Operator + limit:-1 + Stage-1 + Reducer 4 + File Output Operator [FS_19] + Select Operator [SEL_17] (rows=6758 width=215) + Output:["_col0"] + PTF Operator [PTF_16] (rows=6758 width=215) + Function definitions:[{},{"name:":"windowingtablefunction","order by:":"(UDFToDouble(_col1) / UDFToDouble(_col2))","partition by:":"0"}] + Select Operator [SEL_15] (rows=6758 width=215) + Output:["_col1","_col2"] + <-Reducer 3 [SIMPLE_EDGE] + SHUFFLE [RS_14] + PartitionCols:0 + Select Operator [SEL_13] (rows=6758 width=215) + Output:["_col1","_col2"] + Group By Operator [GBY_12] (rows=6758 width=215) + Output:["_col0","_col1","_col2"],aggregations:["sum(VALUE._col0)","sum(VALUE._col1)"],keys:KEY._col0 + <-Reducer 2 [SIMPLE_EDGE] + SHUFFLE [RS_11] + PartitionCols:_col0 + Group By Operator [GBY_10] (rows=13516 width=215) + Output:["_col0","_col1","_col2"],aggregations:["sum(_col3)","sum(_col1)"],keys:_col2 + Select Operator [SEL_9] (rows=13516 width=215) + Output:["_col2","_col3","_col1"] + Merge Join Operator [MERGEJOIN_24] (rows=13516 width=215) + Conds:RS_6._col0=RS_7._col1(Inner),Output:["_col1","_col2","_col3"] + <-Map 1 [SIMPLE_EDGE] + SHUFFLE [RS_6] + PartitionCols:_col0 + Select Operator [SEL_2] (rows=20 width=13) + Output:["_col0","_col1","_col2"] + Filter Operator [FIL_22] (rows=20 width=13) + predicate:value is not null + TableScan [TS_0] (rows=20 width=13) + default@cbo_t3,ws,Tbl:COMPLETE,Col:NONE,Output:["value","c_int","c_boolean"] + <-Map 5 [SIMPLE_EDGE] + SHUFFLE [RS_7] + PartitionCols:_col1 + Select Operator [SEL_5] (rows=12288 width=215) + Output:["_col0","_col1"] + Filter Operator [FIL_23] (rows=12288 width=215) + predicate:cstring1 is not null + TableScan [TS_3] (rows=12288 width=215) + default@alltypesorc,wr,Tbl:COMPLETE,Col:NONE,Output:["cint","cstring1"]