You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2018/02/12 18:42:20 UTC
[10/50] [abbrv] hive git commit: HIVE-18359: Extend grouping set
limits from int to long (Prasanth Jayachandran reviewed by Jesus Camacho
Rodriguez)
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out b/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out
index f2cda04..24be36e 100644
--- a/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out
+++ b/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out
@@ -175,14 +175,14 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 12 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: sum(_col2)
- keys: _col0 (type: int), _col1 (type: int), 0 (type: int)
+ keys: _col0 (type: int), _col1 (type: int), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 3 Data size: 36 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: int), _col1 (type: int), _col2 (type: int)
+ key expressions: _col0 (type: int), _col1 (type: int), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: int), _col1 (type: int), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: int), _col1 (type: int), _col2 (type: bigint)
Statistics: Num rows: 3 Data size: 36 Basic stats: COMPLETE Column stats: NONE
value expressions: _col3 (type: bigint)
Execution mode: vectorized, llap
@@ -192,12 +192,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: sum(VALUE._col0)
- keys: KEY._col0 (type: int), KEY._col1 (type: int), KEY._col2 (type: int)
+ keys: KEY._col0 (type: int), KEY._col1 (type: int), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 1 Data size: 12 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col3 (type: bigint), grouping(_col2, 0) (type: int), 'NULL,1' (type: string)
+ expressions: _col3 (type: bigint), grouping(_col2, 0) (type: bigint), 'NULL,1' (type: string)
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 1 Data size: 12 Basic stats: COMPLETE Column stats: NONE
File Output Operator
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/llap_acid.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/llap_acid.q.out b/ql/src/test/results/clientpositive/llap/llap_acid.q.out
index 38889b9..4ed45e7 100644
--- a/ql/src/test/results/clientpositive/llap/llap_acid.q.out
+++ b/ql/src/test/results/clientpositive/llap/llap_acid.q.out
@@ -174,23 +174,25 @@ POSTHOOK: Input: default@orc_llap@csmallint=1
POSTHOOK: Input: default@orc_llap@csmallint=2
POSTHOOK: Input: default@orc_llap@csmallint=3
#### A masked pattern was here ####
--285355633 1 -1241163445
--109813638 1 -58941842
-164554497 1 1161977292
-199879534 1 123351087
+-838810013 1 1864027286
+-595277064 1 -1645852809
+-334595454 1 -1645852809
+185212032 1 -1645852809
+186967185 1 -1645852809
+241008004 1 -1645852809
246423894 1 -1645852809
-354670578 1 562841852
-455419170 1 1108177470
-665801232 1 480783141
+518213127 1 -1645852809
+584923170 1 -1645852809
708885482 1 -1645852809
--285355633 2 -1241163445
--109813638 2 -58941842
-164554497 2 1161977292
-199879534 2 123351087
+-838810013 2 1864027286
+-595277064 2 -1645852809
+-334595454 2 -1645852809
+185212032 2 -1645852809
+186967185 2 -1645852809
+241008004 2 -1645852809
246423894 2 -1645852809
-354670578 2 562841852
-455419170 2 1108177470
-665801232 2 480783141
+518213127 2 -1645852809
+584923170 2 -1645852809
708885482 2 -1645852809
-923308739 3 -1887561756
-3728 3 -1887561756
@@ -424,24 +426,26 @@ POSTHOOK: Input: default@orc_llap@csmallint=1
POSTHOOK: Input: default@orc_llap@csmallint=2
POSTHOOK: Input: default@orc_llap@csmallint=3
#### A masked pattern was here ####
--285355633 1 -1241163445
--109813638 1 -58941842
+-838810013 1 1864027286
+-595277064 1 -1645852809
+-334595454 1 -1645852809
1 1 2
-164554497 1 1161977292
-199879534 1 123351087
+185212032 1 -1645852809
+186967185 1 -1645852809
+241008004 1 -1645852809
246423894 1 -1645852809
-354670578 1 562841852
-455419170 1 1108177470
-665801232 1 480783141
+518213127 1 -1645852809
+584923170 1 -1645852809
708885482 1 -1645852809
--285355633 2 -1241163445
--109813638 2 -58941842
-164554497 2 1161977292
-199879534 2 123351087
+-838810013 2 1864027286
+-595277064 2 -1645852809
+-334595454 2 -1645852809
+185212032 2 -1645852809
+186967185 2 -1645852809
+241008004 2 -1645852809
246423894 2 -1645852809
-354670578 2 562841852
-455419170 2 1108177470
-665801232 2 480783141
+518213127 2 -1645852809
+584923170 2 -1645852809
708885482 2 -1645852809
-923308739 3 -1887561756
-3728 3 -1887561756
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/llap_acid_fast.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/llap_acid_fast.q.out b/ql/src/test/results/clientpositive/llap/llap_acid_fast.q.out
index 4a7297d..42af8e6 100644
--- a/ql/src/test/results/clientpositive/llap/llap_acid_fast.q.out
+++ b/ql/src/test/results/clientpositive/llap/llap_acid_fast.q.out
@@ -168,23 +168,25 @@ POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=1
POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=2
POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=3
#### A masked pattern was here ####
--285355633 1 -1241163445
--109813638 1 -58941842
-164554497 1 1161977292
-199879534 1 123351087
+-838810013 1 1864027286
+-595277064 1 -1645852809
+-334595454 1 -1645852809
+185212032 1 -1645852809
+186967185 1 -1645852809
+241008004 1 -1645852809
246423894 1 -1645852809
-354670578 1 562841852
-455419170 1 1108177470
-665801232 1 480783141
+518213127 1 -1645852809
+584923170 1 -1645852809
708885482 1 -1645852809
--285355633 2 -1241163445
--109813638 2 -58941842
-164554497 2 1161977292
-199879534 2 123351087
+-838810013 2 1864027286
+-595277064 2 -1645852809
+-334595454 2 -1645852809
+185212032 2 -1645852809
+186967185 2 -1645852809
+241008004 2 -1645852809
246423894 2 -1645852809
-354670578 2 562841852
-455419170 2 1108177470
-665801232 2 480783141
+518213127 2 -1645852809
+584923170 2 -1645852809
708885482 2 -1645852809
-923308739 3 -1887561756
-3728 3 -1887561756
@@ -418,24 +420,26 @@ POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=1
POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=2
POSTHOOK: Input: default@orc_llap_acid_fast@csmallint=3
#### A masked pattern was here ####
--285355633 1 -1241163445
--109813638 1 -58941842
+-838810013 1 1864027286
+-595277064 1 -1645852809
+-334595454 1 -1645852809
1 1 2
-164554497 1 1161977292
-199879534 1 123351087
+185212032 1 -1645852809
+186967185 1 -1645852809
+241008004 1 -1645852809
246423894 1 -1645852809
-354670578 1 562841852
-455419170 1 1108177470
-665801232 1 480783141
+518213127 1 -1645852809
+584923170 1 -1645852809
708885482 1 -1645852809
--285355633 2 -1241163445
--109813638 2 -58941842
-164554497 2 1161977292
-199879534 2 123351087
+-838810013 2 1864027286
+-595277064 2 -1645852809
+-334595454 2 -1645852809
+185212032 2 -1645852809
+186967185 2 -1645852809
+241008004 2 -1645852809
246423894 2 -1645852809
-354670578 2 562841852
-455419170 2 1108177470
-665801232 2 480783141
+518213127 2 -1645852809
+584923170 2 -1645852809
708885482 2 -1645852809
-923308739 3 -1887561756
-3728 3 -1887561756
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/multi_count_distinct_null.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/multi_count_distinct_null.q.out b/ql/src/test/results/clientpositive/llap/multi_count_distinct_null.q.out
index 1f17f96..66bf74f 100644
--- a/ql/src/test/results/clientpositive/llap/multi_count_distinct_null.q.out
+++ b/ql/src/test/results/clientpositive/llap/multi_count_distinct_null.q.out
@@ -48,29 +48,29 @@ STAGE PLANS:
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 1023 Basic stats: COMPLETE Column stats: COMPLETE
Group By Operator
- keys: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), 0 (type: int)
+ keys: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
- Statistics: Num rows: 18 Data size: 1556 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 18 Data size: 1628 Basic stats: COMPLETE Column stats: COMPLETE
Reduce Output Operator
- key expressions: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), _col3 (type: int)
+ key expressions: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), _col3 (type: bigint)
sort order: ++++
- Map-reduce partition columns: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), _col3 (type: int)
- Statistics: Num rows: 18 Data size: 1556 Basic stats: COMPLETE Column stats: COMPLETE
+ Map-reduce partition columns: _col0 (type: int), _col1 (type: varchar(10)), _col2 (type: int), _col3 (type: bigint)
+ Statistics: Num rows: 18 Data size: 1628 Basic stats: COMPLETE Column stats: COMPLETE
Execution mode: llap
LLAP IO: no inputs
Reducer 2
Execution mode: llap
Reduce Operator Tree:
Group By Operator
- keys: KEY._col0 (type: int), KEY._col1 (type: varchar(10)), KEY._col2 (type: int), KEY._col3 (type: int)
+ keys: KEY._col0 (type: int), KEY._col1 (type: varchar(10)), KEY._col2 (type: int), KEY._col3 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2, _col3
- Statistics: Num rows: 18 Data size: 1556 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 18 Data size: 1628 Basic stats: COMPLETE Column stats: COMPLETE
Select Operator
expressions: CASE WHEN (((_col3 = 3) and _col0 is not null)) THEN (1) ELSE (null) END (type: int), CASE WHEN (((_col3 = 5) and _col1 is not null)) THEN (1) ELSE (null) END (type: int), CASE WHEN (((_col3 = 6) and _col2 is not null)) THEN (1) ELSE (null) END (type: int)
outputColumnNames: _col0, _col1, _col2
- Statistics: Num rows: 18 Data size: 1556 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 18 Data size: 1628 Basic stats: COMPLETE Column stats: COMPLETE
Group By Operator
aggregations: count(_col0), count(_col1), count(_col2)
mode: hash
@@ -189,29 +189,29 @@ STAGE PLANS:
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 1023 Basic stats: COMPLETE Column stats: COMPLETE
Group By Operator
- keys: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), 0 (type: int)
+ keys: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
- Statistics: Num rows: 30 Data size: 2534 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 30 Data size: 2654 Basic stats: COMPLETE Column stats: COMPLETE
Reduce Output Operator
- key expressions: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), _col3 (type: int)
+ key expressions: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), _col3 (type: bigint)
sort order: ++++
- Map-reduce partition columns: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), _col3 (type: int)
- Statistics: Num rows: 30 Data size: 2534 Basic stats: COMPLETE Column stats: COMPLETE
+ Map-reduce partition columns: _col0 (type: varchar(10)), _col1 (type: int), _col2 (type: int), _col3 (type: bigint)
+ Statistics: Num rows: 30 Data size: 2654 Basic stats: COMPLETE Column stats: COMPLETE
Execution mode: llap
LLAP IO: no inputs
Reducer 2
Execution mode: llap
Reduce Operator Tree:
Group By Operator
- keys: KEY._col0 (type: varchar(10)), KEY._col1 (type: int), KEY._col2 (type: int), KEY._col3 (type: int)
+ keys: KEY._col0 (type: varchar(10)), KEY._col1 (type: int), KEY._col2 (type: int), KEY._col3 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2, _col3
- Statistics: Num rows: 30 Data size: 2534 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 30 Data size: 2654 Basic stats: COMPLETE Column stats: COMPLETE
Select Operator
expressions: CASE WHEN (((_col3 = 3) and _col0 is not null)) THEN (1) ELSE (null) END (type: int), CASE WHEN (((_col3 = 5) and _col1 is not null)) THEN (1) ELSE (null) END (type: int), CASE WHEN (((_col3 = 6) and _col2 is not null)) THEN (1) ELSE (null) END (type: int), CASE WHEN ((_col3 = 4)) THEN (1) ELSE (null) END (type: int), CASE WHEN ((_col3 = 0)) THEN (1) ELSE (null) END (type: int)
outputColumnNames: _col0, _col1, _col2, _col3, _col4
- Statistics: Num rows: 30 Data size: 2534 Basic stats: COMPLETE Column stats: COMPLETE
+ Statistics: Num rows: 30 Data size: 2654 Basic stats: COMPLETE Column stats: COMPLETE
Group By Operator
aggregations: count(_col0), count(_col1), count(_col2), count(_col3), count(_col4)
mode: hash
@@ -291,24 +291,24 @@ group by department_id, gender, education_level grouping sets
POSTHOOK: type: QUERY
POSTHOOK: Input: default@employee
POSTHOOK: Output: hdfs://### HDFS PATH ###
+5 NULL NULL NULL
+2 NULL NULL 1
+2 1 NULL 1
+2 1 NULL 3
+3 4 NULL NULL
+2 4 NULL 1
+3 NULL NULL NULL
6 NULL NULL NULL
6 NULL NULL 2
5 NULL F NULL
+3 1 NULL NULL
2 2 NULL 3
-2 NULL NULL NULL
-2 NULL NULL 1
-2 1 NULL 3
+6 NULL NULL 3
3 2 NULL NULL
2 2 NULL 1
-3 3 NULL NULL
-2 3 NULL 2
-3 NULL NULL NULL
-5 NULL NULL NULL
+2 NULL NULL NULL
+6 NULL NULL 1
5 NULL M NULL
-2 1 NULL 1
2 1 NULL 2
-2 4 NULL 1
-6 NULL NULL 1
-6 NULL NULL 3
-3 1 NULL NULL
-3 4 NULL NULL
+3 3 NULL NULL
+2 3 NULL 2
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/vector_groupby_cube1.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/vector_groupby_cube1.q.out b/ql/src/test/results/clientpositive/llap/vector_groupby_cube1.q.out
index 39de888..04ac09b 100644
--- a/ql/src/test/results/clientpositive/llap/vector_groupby_cube1.q.out
+++ b/ql/src/test/results/clientpositive/llap/vector_groupby_cube1.q.out
@@ -47,14 +47,14 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count()
- keys: key (type: string), val (type: string), 0 (type: int)
+ keys: key (type: string), val (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
value expressions: _col3 (type: bigint)
Execution mode: llap
@@ -64,7 +64,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -120,14 +120,14 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count()
- keys: key (type: string), val (type: string), 0 (type: int)
+ keys: key (type: string), val (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
value expressions: _col3 (type: bigint)
Execution mode: llap
@@ -137,7 +137,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -219,14 +219,14 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count()
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
value expressions: _col3 (type: bigint)
Execution mode: llap
@@ -236,12 +236,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int), _col3 (type: bigint)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint), _col3 (type: bigint)
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
File Output Operator
@@ -317,14 +317,14 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count(DISTINCT val)
- keys: key (type: string), 0 (type: int), val (type: string)
+ keys: key (type: string), 0 (type: bigint), val (type: string)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: int), _col2 (type: string)
+ key expressions: _col0 (type: string), _col1 (type: bigint), _col2 (type: string)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: bigint)
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
Execution mode: llap
LLAP IO: no inputs
@@ -333,7 +333,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(DISTINCT KEY._col2:0._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col2
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
@@ -404,12 +404,12 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count()
- keys: key (type: string), val (type: string), 0 (type: int)
+ keys: key (type: string), val (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: rand() (type: double)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -421,12 +421,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: partials
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: _col0 (type: string), _col1 (type: string)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -436,7 +436,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: final
outputColumnNames: _col0, _col1, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -519,12 +519,12 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count(DISTINCT val)
- keys: key (type: string), 0 (type: int), val (type: string)
+ keys: key (type: string), 0 (type: bigint), val (type: string)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: int), _col2 (type: string)
+ key expressions: _col0 (type: string), _col1 (type: bigint), _col2 (type: string)
sort order: +++
Map-reduce partition columns: _col0 (type: string)
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -535,12 +535,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(DISTINCT KEY._col2:0._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: bigint)
mode: partials
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: bigint)
sort order: ++
Map-reduce partition columns: _col0 (type: string)
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -550,7 +550,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: bigint)
mode: final
outputColumnNames: _col0, _col2
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
@@ -649,12 +649,12 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: count(1)
- keys: key (type: string), val (type: string), 0 (type: int)
+ keys: key (type: string), val (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: rand() (type: double)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -665,12 +665,12 @@ STAGE PLANS:
Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE
Group By Operator
aggregations: sum(1)
- keys: key (type: string), val (type: string), 0 (type: int)
+ keys: key (type: string), val (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: rand() (type: double)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -682,12 +682,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: partials
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: _col0 (type: string), _col1 (type: string)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -697,7 +697,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: count(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: final
outputColumnNames: _col0, _col1, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
@@ -747,12 +747,12 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: sum(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: partials
outputColumnNames: _col0, _col1, _col2, _col3
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
Map-reduce partition columns: _col0 (type: string), _col1 (type: string)
Statistics: Num rows: 4 Data size: 1472 Basic stats: COMPLETE Column stats: NONE
@@ -762,7 +762,7 @@ STAGE PLANS:
Reduce Operator Tree:
Group By Operator
aggregations: sum(VALUE._col0)
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: final
outputColumnNames: _col0, _col1, _col3
Statistics: Num rows: 2 Data size: 736 Basic stats: COMPLETE Column stats: NONE
http://git-wip-us.apache.org/repos/asf/hive/blob/ddd4c9ae/ql/src/test/results/clientpositive/llap/vector_groupby_grouping_id1.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/llap/vector_groupby_grouping_id1.q.out b/ql/src/test/results/clientpositive/llap/vector_groupby_grouping_id1.q.out
index 7224d59..fd9dacb 100644
--- a/ql/src/test/results/clientpositive/llap/vector_groupby_grouping_id1.q.out
+++ b/ql/src/test/results/clientpositive/llap/vector_groupby_grouping_id1.q.out
@@ -70,18 +70,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 24 Data size: 8832 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -118,7 +118,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -126,16 +126,16 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
outputColumnNames: _col0, _col1, _col2
Select Vectorization:
className: VectorSelectOperator
@@ -229,18 +229,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 24 Data size: 8832 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -277,7 +277,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -285,16 +285,16 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
outputColumnNames: _col0, _col1, _col2
Select Vectorization:
className: VectorSelectOperator
@@ -388,18 +388,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 18 Data size: 6624 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -436,7 +436,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -444,16 +444,16 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 9 Data size: 3312 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col2 (type: int), _col0 (type: string), _col1 (type: string)
+ expressions: _col2 (type: bigint), _col0 (type: string), _col1 (type: string)
outputColumnNames: _col0, _col1, _col2
Select Vectorization:
className: VectorSelectOperator
@@ -541,18 +541,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 18 Data size: 6624 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -589,7 +589,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -597,16 +597,16 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 9 Data size: 3312 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col2 (type: int), _col0 (type: string), _col1 (type: string)
+ expressions: _col2 (type: bigint), _col0 (type: string), _col1 (type: string)
outputColumnNames: _col0, _col1, _col2
Select Vectorization:
className: VectorSelectOperator
@@ -694,18 +694,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 24 Data size: 8832 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -742,7 +742,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -750,22 +750,22 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int), CASE WHEN ((_col2 = 0)) THEN ('0') WHEN ((_col2 = 1)) THEN ('1') WHEN ((_col2 = 2)) THEN ('2') WHEN ((_col2 = 3)) THEN ('3') ELSE ('nothing') END (type: string)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint), CASE WHEN ((_col2 = 0)) THEN ('0') WHEN ((_col2 = 1)) THEN ('1') WHEN ((_col2 = 2)) THEN ('2') WHEN ((_col2 = 3)) THEN ('3') ELSE ('nothing') END (type: string)
outputColumnNames: _col0, _col1, _col2, _col3
Select Vectorization:
className: VectorSelectOperator
native: true
projectedOutputColumnNums: [0, 1, 2, 8]
- selectExpressions: IfExprStringScalarStringGroupColumn(col 3:boolean, val 0col 7:string)(children: LongColEqualLongScalar(col 2:int, val 0) -> 3:boolean, IfExprStringScalarStringGroupColumn(col 4:boolean, val 1col 8:string)(children: LongColEqualLongScalar(col 2:int, val 1) -> 4:boolean, IfExprStringScalarStringGroupColumn(col 5:boolean, val 2col 7:string)(children: LongColEqualLongScalar(col 2:int, val 2) -> 5:boolean, IfExprStringScalarStringScalar(col 6:boolean, val 3, val nothing)(children: LongColEqualLongScalar(col 2:int, val 3) -> 6:boolean) -> 7:string) -> 8:string) -> 7:string) -> 8:string
+ selectExpressions: IfExprStringScalarStringGroupColumn(col 3:boolean, val 0col 7:string)(children: LongColEqualLongScalar(col 2:bigint, val 0) -> 3:boolean, IfExprStringScalarStringGroupColumn(col 4:boolean, val 1col 8:string)(children: LongColEqualLongScalar(col 2:bigint, val 1) -> 4:boolean, IfExprStringScalarStringGroupColumn(col 5:boolean, val 2col 7:string)(children: LongColEqualLongScalar(col 2:bigint, val 2) -> 5:boolean, IfExprStringScalarStringScalar(col 6:boolean, val 3, val nothing)(children: LongColEqualLongScalar(col 2:bigint, val 3) -> 6:boolean) -> 7:string) -> 8:string) -> 7:string) -> 8:string
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
File Output Operator
compressed: false
@@ -854,18 +854,18 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: HASH
- keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:int
+ keyExpressions: col 0:string, col 1:string, ConstantVectorExpression(val 0) -> 3:bigint
native: false
vectorProcessingMode: HASH
projectedOutputColumnNums: []
- keys: _col0 (type: string), _col1 (type: string), 0 (type: int)
+ keys: _col0 (type: string), _col1 (type: string), 0 (type: bigint)
mode: hash
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 24 Data size: 8832 Basic stats: COMPLETE Column stats: NONE
Reduce Output Operator
- key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ key expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
sort order: +++
- Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: int)
+ Map-reduce partition columns: _col0 (type: string), _col1 (type: string), _col2 (type: bigint)
Reduce Sink Vectorization:
className: VectorReduceSinkMultiKeyOperator
keyColumnNums: [0, 1, 2]
@@ -902,7 +902,7 @@ STAGE PLANS:
vectorized: true
rowBatchContext:
dataColumnCount: 3
- dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:int
+ dataColumns: KEY._col0:string, KEY._col1:string, KEY._col2:bigint
partitionColumnCount: 0
scratchColumnTypeNames: []
Reduce Operator Tree:
@@ -910,22 +910,22 @@ STAGE PLANS:
Group By Vectorization:
className: VectorGroupByOperator
groupByMode: MERGEPARTIAL
- keyExpressions: col 0:string, col 1:string, col 2:int
+ keyExpressions: col 0:string, col 1:string, col 2:bigint
native: false
vectorProcessingMode: MERGE_PARTIAL
projectedOutputColumnNums: []
- keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: int)
+ keys: KEY._col0 (type: string), KEY._col1 (type: string), KEY._col2 (type: bigint)
mode: mergepartial
outputColumnNames: _col0, _col1, _col2
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
Select Operator
- expressions: _col0 (type: string), _col1 (type: string), _col2 (type: int), CASE WHEN ((_col2 = 0)) THEN ('0') WHEN ((_col2 = 1)) THEN ('1') WHEN ((_col2 = 2)) THEN ('2') WHEN ((_col2 = 3)) THEN ('3') ELSE ('nothing') END (type: string)
+ expressions: _col0 (type: string), _col1 (type: string), _col2 (type: bigint), CASE WHEN ((_col2 = 0)) THEN ('0') WHEN ((_col2 = 1)) THEN ('1') WHEN ((_col2 = 2)) THEN ('2') WHEN ((_col2 = 3)) THEN ('3') ELSE ('nothing') END (type: string)
outputColumnNames: _col0, _col1, _col2, _col3
Select Vectorization:
className: VectorSelectOperator
native: true
projectedOutputColumnNums: [0, 1, 2, 8]
- selectExpressions: IfExprStringScalarStringGroupColumn(col 3:boolean, val 0col 7:string)(children: LongColEqualLongScalar(col 2:int, val 0) -> 3:boolean, IfExprStringScalarStringGroupColumn(col 4:boolean, val 1col 8:string)(children: LongColEqualLongScalar(col 2:int, val 1) -> 4:boolean, IfExprStringScalarStringGroupColumn(col 5:boolean, val 2col 7:string)(children: LongColEqualLongScalar(col 2:int, val 2) -> 5:boolean, IfExprStringScalarStringScalar(col 6:boolean, val 3, val nothing)(children: LongColEqualLongScalar(col 2:int, val 3) -> 6:boolean) -> 7:string) -> 8:string) -> 7:string) -> 8:string
+ selectExpressions: IfExprStringScalarStringGroupColumn(col 3:boolean, val 0col 7:string)(children: LongColEqualLongScalar(col 2:bigint, val 0) -> 3:boolean, IfExprStringScalarStringGroupColumn(col 4:boolean, val 1col 8:string)(children: LongColEqualLongScalar(col 2:bigint, val 1) -> 4:boolean, IfExprStringScalarStringGroupColumn(col 5:boolean, val 2col 7:string)(children: LongColEqualLongScalar(col 2:bigint, val 2) -> 5:boolean, IfExprStringScalarStringScalar(col 6:boolean, val 3, val nothing)(children: LongColEqualLongScalar(col 2:bigint, val 3) -> 6:boolean) -> 7:string) -> 8:string) -> 7:string) -> 8:string
Statistics: Num rows: 12 Data size: 4416 Basic stats: COMPLETE Column stats: NONE
File Output Operator
compressed: false