diff --git data/files/alltypesagg.txt data/files/alltypesagg.txt new file mode 100644 index 0000000..34666e1 --- /dev/null +++ data/files/alltypesagg.txt @@ -0,0 +1,101 @@ +0,true,,,,,,,01/01/10,0,2010-01-01 00:00:00.0 +1,false,1,1,1,10,1.1,10.1,01/01/10,1,2010-01-01 00:01:00.0 +2,true,2,2,2,20,2.2,20.2,01/01/10,2,2010-01-01 00:02:00.10 +3,false,3,3,3,30,3.3,30.299999999999997,01/01/10,3,2010-01-01 00:03:00.30 +4,true,4,4,4,40,4.4,40.4,01/01/10,4,2010-01-01 00:04:00.60 +5,false,5,5,5,50,5.5,50.5,01/01/10,5,2010-01-01 00:05:00.100 +6,true,6,6,6,60,6.6,60.599999999999994,01/01/10,6,2010-01-01 00:06:00.150 +7,false,7,7,7,70,7.7,70.7,01/01/10,7,2010-01-01 00:07:00.210 +8,true,8,8,8,80,8.8,80.8,01/01/10,8,2010-01-01 00:08:00.280 +9,false,9,9,9,90,9.9,90.89999999999999,01/01/10,9,2010-01-01 00:09:00.360 +10,true,,10,10,100,11.0,101.0,01/01/10,10,2010-01-01 00:10:00.450 +11,false,1,11,11,110,12.1,111.1,01/01/10,11,2010-01-01 00:11:00.550 +12,true,2,12,12,120,13.2,121.19999999999999,01/01/10,12,2010-01-01 00:12:00.660 +13,false,3,13,13,130,14.3,131.29999999999998,01/01/10,13,2010-01-01 00:13:00.780 +14,true,4,14,14,140,15.4,141.4,01/01/10,14,2010-01-01 00:14:00.910 +15,false,5,15,15,150,16.5,151.5,01/01/10,15,2010-01-01 00:15:01.50 +16,true,6,16,16,160,17.6,161.6,01/01/10,16,2010-01-01 00:16:01.200 +17,false,7,17,17,170,18.7,171.7,01/01/10,17,2010-01-01 00:17:01.360 +18,true,8,18,18,180,19.8,181.79999999999998,01/01/10,18,2010-01-01 00:18:01.530 +19,false,9,19,19,190,20.9,191.9,01/01/10,19,2010-01-01 00:19:01.710 +20,true,,20,20,200,22.0,202.0,01/01/10,20,2010-01-01 00:20:01.900 +21,false,1,21,21,210,23.1,212.1,01/01/10,21,2010-01-01 00:21:02.100 +22,true,2,22,22,220,24.2,222.2,01/01/10,22,2010-01-01 00:22:02.310 +23,false,3,23,23,230,25.3,232.29999999999998,01/01/10,23,2010-01-01 00:23:02.530 +24,true,4,24,24,240,26.4,242.39999999999998,01/01/10,24,2010-01-01 00:24:02.760 +25,false,5,25,25,250,27.5,252.5,01/01/10,25,2010-01-01 00:25:03.0 +26,true,6,26,26,260,28.6,262.59999999999997,01/01/10,26,2010-01-01 00:26:03.250 +27,false,7,27,27,270,29.7,272.7,01/01/10,27,2010-01-01 00:27:03.510 +28,true,8,28,28,280,30.8,282.8,01/01/10,28,2010-01-01 00:28:03.780 +29,false,9,29,29,290,31.9,292.9,01/01/10,29,2010-01-01 00:29:04.60 +30,true,,30,30,300,33.0,303.0,01/01/10,30,2010-01-01 00:30:04.350 +31,false,1,31,31,310,34.1,313.09999999999997,01/01/10,31,2010-01-01 00:31:04.650 +32,true,2,32,32,320,35.2,323.2,01/01/10,32,2010-01-01 00:32:04.960 +33,false,3,33,33,330,36.3,333.3,01/01/10,33,2010-01-01 00:33:05.280 +34,true,4,34,34,340,37.4,343.4,01/01/10,34,2010-01-01 00:34:05.610 +35,false,5,35,35,350,38.5,353.5,01/01/10,35,2010-01-01 00:35:05.950 +36,true,6,36,36,360,39.6,363.59999999999997,01/01/10,36,2010-01-01 00:36:06.300 +37,false,7,37,37,370,40.7,373.7,01/01/10,37,2010-01-01 00:37:06.660 +38,true,8,38,38,380,41.8,383.8,01/01/10,38,2010-01-01 00:38:07.30 +39,false,9,39,39,390,42.9,393.9,01/01/10,39,2010-01-01 00:39:07.410 +40,true,,40,40,400,44.0,404.0,01/01/10,40,2010-01-01 00:40:07.800 +41,false,1,41,41,410,45.1,414.09999999999997,01/01/10,41,2010-01-01 00:41:08.200 +42,true,2,42,42,420,46.2,424.2,01/01/10,42,2010-01-01 00:42:08.610 +43,false,3,43,43,430,47.3,434.3,01/01/10,43,2010-01-01 00:43:09.30 +44,true,4,44,44,440,48.4,444.4,01/01/10,44,2010-01-01 00:44:09.460 +45,false,5,45,45,450,49.5,454.5,01/01/10,45,2010-01-01 00:45:09.900 +46,true,6,46,46,460,50.6,464.59999999999997,01/01/10,46,2010-01-01 00:46:10.350 +47,false,7,47,47,470,51.7,474.7,01/01/10,47,2010-01-01 00:47:10.810 +48,true,8,48,48,480,52.8,484.79999999999995,01/01/10,48,2010-01-01 00:48:11.280 +49,false,9,49,49,490,53.9,494.9,01/01/10,49,2010-01-01 00:49:11.760 +50,true,,50,50,500,55.0,505.0,01/01/10,50,2010-01-01 00:50:12.250 +51,false,1,51,51,510,56.1,515.1,01/01/10,51,2010-01-01 00:51:12.750 +52,true,2,52,52,520,57.2,525.1999999999999,01/01/10,52,2010-01-01 00:52:13.260 +53,false,3,53,53,530,58.3,535.3,01/01/10,53,2010-01-01 00:53:13.780 +54,true,4,54,54,540,59.4,545.4,01/01/10,54,2010-01-01 00:54:14.310 +55,false,5,55,55,550,60.5,555.5,01/01/10,55,2010-01-01 00:55:14.850 +56,true,6,56,56,560,61.6,565.6,01/01/10,56,2010-01-01 00:56:15.400 +57,false,7,57,57,570,62.7,575.6999999999999,01/01/10,57,2010-01-01 00:57:15.960 +58,true,8,58,58,580,63.8,585.8,01/01/10,58,2010-01-01 00:58:16.530 +59,false,9,59,59,590,64.9,595.9,01/01/10,59,2010-01-01 00:59:17.110 +60,true,,60,60,600,66.0,606.0,01/01/10,60,2010-01-01 01:00:17.700 +61,false,1,61,61,610,67.1,616.1,01/01/10,61,2010-01-01 01:01:18.300 +62,true,2,62,62,620,68.2,626.1999999999999,01/01/10,62,2010-01-01 01:02:18.910 +63,false,3,63,63,630,69.3,636.3,01/01/10,63,2010-01-01 01:03:19.530 +64,true,4,64,64,640,70.4,646.4,01/01/10,64,2010-01-01 01:04:20.160 +65,false,5,65,65,650,71.5,656.5,01/01/10,65,2010-01-01 01:05:20.800 +66,true,6,66,66,660,72.6,666.6,01/01/10,66,2010-01-01 01:06:21.450 +67,false,7,67,67,670,73.7,676.6999999999999,01/01/10,67,2010-01-01 01:07:22.110 +68,true,8,68,68,680,74.8,686.8,01/01/10,68,2010-01-01 01:08:22.780 +69,false,9,69,69,690,75.9,696.9,01/01/10,69,2010-01-01 01:09:23.460 +70,true,,70,70,700,77.0,707.0,01/01/10,70,2010-01-01 01:10:24.150 +71,false,1,71,71,710,78.1,717.1,01/01/10,71,2010-01-01 01:11:24.850 +72,true,2,72,72,720,79.2,727.1999999999999,01/01/10,72,2010-01-01 01:12:25.560 +73,false,3,73,73,730,80.3,737.3,01/01/10,73,2010-01-01 01:13:26.280 +74,true,4,74,74,740,81.4,747.4,01/01/10,74,2010-01-01 01:14:27.10 +75,false,5,75,75,750,82.5,757.5,01/01/10,75,2010-01-01 01:15:27.750 +76,true,6,76,76,760,83.6,767.6,01/01/10,76,2010-01-01 01:16:28.500 +77,false,7,77,77,770,84.7,777.6999999999999,01/01/10,77,2010-01-01 01:17:29.260 +78,true,8,78,78,780,85.8,787.8,01/01/10,78,2010-01-01 01:18:30.30 +79,false,9,79,79,790,86.9,797.9,01/01/10,79,2010-01-01 01:19:30.810 +80,true,,80,80,800,88.0,808.0,01/01/10,80,2010-01-01 01:20:31.600 +81,false,1,81,81,810,89.1,818.1,01/01/10,81,2010-01-01 01:21:32.400 +82,true,2,82,82,820,90.2,828.1999999999999,01/01/10,82,2010-01-01 01:22:33.210 +83,false,3,83,83,830,91.3,838.3,01/01/10,83,2010-01-01 01:23:34.30 +84,true,4,84,84,840,92.4,848.4,01/01/10,84,2010-01-01 01:24:34.860 +85,false,5,85,85,850,93.5,858.5,01/01/10,85,2010-01-01 01:25:35.700 +86,true,6,86,86,860,94.6,868.6,01/01/10,86,2010-01-01 01:26:36.550 +87,false,7,87,87,870,95.7,878.6999999999999,01/01/10,87,2010-01-01 01:27:37.410 +88,true,8,88,88,880,96.8,888.8,01/01/10,88,2010-01-01 01:28:38.280 +89,false,9,89,89,890,97.9,898.9,01/01/10,89,2010-01-01 01:29:39.160 +90,true,,90,90,900,99.0,909.0,01/01/10,90,2010-01-01 01:30:40.50 +91,false,1,91,91,910,100.1,919.1,01/01/10,91,2010-01-01 01:31:40.950 +92,true,2,92,92,920,101.2,929.1999999999999,01/01/10,92,2010-01-01 01:32:41.860 +93,false,3,93,93,930,102.3,939.3,01/01/10,93,2010-01-01 01:33:42.780 +94,true,4,94,94,940,103.4,949.4,01/01/10,94,2010-01-01 01:34:43.710 +95,false,5,95,95,950,104.5,959.5,01/01/10,95,2010-01-01 01:35:44.650 +96,true,6,96,96,960,105.6,969.5999999999999,01/01/10,96,2010-01-01 01:36:45.600 +97,false,7,97,97,970,106.7,979.6999999999999,01/01/10,97,2010-01-01 01:37:46.560 +98,true,8,98,98,980,107.8,989.8,01/01/10,98,2010-01-01 01:38:47.530 +99,false,9,99,99,990,108.9,999.9,01/01/10,99,2010-01-01 01:39:48.510 +100,true,,,100,1000,110.0,1010.0,01/01/10,100,2010-01-01 01:40:49.500 diff --git ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetByteInspector.java ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetByteInspector.java index d5d1bf1..0651e44 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetByteInspector.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetByteInspector.java @@ -53,4 +53,9 @@ public byte get(Object o) { } return ((ByteWritable) o).get(); } + + @Override + public Object getPrimitiveJavaObject(Object o) { + return get(o); + } } diff --git ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetShortInspector.java ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetShortInspector.java index 94f2813..226e33d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetShortInspector.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/parquet/serde/primitive/ParquetShortInspector.java @@ -53,4 +53,9 @@ public short get(Object o) { } return ((ShortWritable) o).get(); } + + @Override + public Object getPrimitiveJavaObject(Object o) { + return get(o); + } } diff --git ql/src/test/queries/clientpositive/parquet_agg.q ql/src/test/queries/clientpositive/parquet_agg.q new file mode 100644 index 0000000..6d6d9f9 --- /dev/null +++ ql/src/test/queries/clientpositive/parquet_agg.q @@ -0,0 +1,40 @@ +DROP TABLE alltypesagg; +DROP TABLE commontypesagg; + +CREATE EXTERNAL TABLE IF NOT EXISTS alltypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string, +timestamp_col timestamp) +ROW FORMAT delimited fields terminated by ',' escaped by '' +stored as textfile; + +LOAD DATA LOCAL INPATH '../../data/files/alltypesagg.txt' OVERWRITE INTO TABLE alltypesagg; + + +CREATE TABLE IF NOT EXISTS commontypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string) +STORED AS PARQUET; + + +INSERT OVERWRITE TABLE commontypesagg SELECT id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col FROM alltypesagg; + +SELECT COUNT(smallint_col), MIN(smallint_col) AS col, MAX(smallint_col), SUM(smallint_col) FROM commontypesagg GROUP BY (smallint_col) ORDER BY col; + +SELECT COUNT(tinyint_col), MIN(tinyint_col) AS col, MAX(tinyint_col), SUM(tinyint_col) FROM commontypesagg GROUP BY (tinyint_col) ORDER BY col; \ No newline at end of file diff --git ql/src/test/results/clientpositive/parquet_agg.q.out ql/src/test/results/clientpositive/parquet_agg.q.out new file mode 100644 index 0000000..06f24a0 --- /dev/null +++ ql/src/test/results/clientpositive/parquet_agg.q.out @@ -0,0 +1,242 @@ +PREHOOK: query: DROP TABLE alltypesagg +PREHOOK: type: DROPTABLE +POSTHOOK: query: DROP TABLE alltypesagg +POSTHOOK: type: DROPTABLE +PREHOOK: query: DROP TABLE commontypesagg +PREHOOK: type: DROPTABLE +POSTHOOK: query: DROP TABLE commontypesagg +POSTHOOK: type: DROPTABLE +PREHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS alltypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string, +timestamp_col timestamp) +ROW FORMAT delimited fields terminated by ',' escaped by '' +stored as textfile +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +POSTHOOK: query: CREATE EXTERNAL TABLE IF NOT EXISTS alltypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string, +timestamp_col timestamp) +ROW FORMAT delimited fields terminated by ',' escaped by '' +stored as textfile +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@alltypesagg +PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/alltypesagg.txt' OVERWRITE INTO TABLE alltypesagg +PREHOOK: type: LOAD +#### A masked pattern was here #### +PREHOOK: Output: default@alltypesagg +POSTHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/alltypesagg.txt' OVERWRITE INTO TABLE alltypesagg +POSTHOOK: type: LOAD +#### A masked pattern was here #### +POSTHOOK: Output: default@alltypesagg +PREHOOK: query: CREATE TABLE IF NOT EXISTS commontypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string) +STORED AS PARQUET +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +POSTHOOK: query: CREATE TABLE IF NOT EXISTS commontypesagg ( +id int, +bool_col boolean, +tinyint_col tinyint, +smallint_col smallint, +int_col int, +bigint_col bigint, +float_col float, +double_col double, +date_string_col string, +string_col string) +STORED AS PARQUET +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@commontypesagg +PREHOOK: query: INSERT OVERWRITE TABLE commontypesagg SELECT id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col FROM alltypesagg +PREHOOK: type: QUERY +PREHOOK: Input: default@alltypesagg +PREHOOK: Output: default@commontypesagg +POSTHOOK: query: INSERT OVERWRITE TABLE commontypesagg SELECT id, bool_col, tinyint_col, smallint_col, int_col, bigint_col, float_col, double_col, date_string_col, string_col FROM alltypesagg +POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypesagg +POSTHOOK: Output: default@commontypesagg +POSTHOOK: Lineage: commontypesagg.bigint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bigint_col, type:bigint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.bool_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bool_col, type:boolean, comment:null), ] +POSTHOOK: Lineage: commontypesagg.date_string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:date_string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.double_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:double_col, type:double, comment:null), ] +POSTHOOK: Lineage: commontypesagg.float_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:float_col, type:float, comment:null), ] +POSTHOOK: Lineage: commontypesagg.id SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:id, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.int_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:int_col, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.smallint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:smallint_col, type:smallint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.tinyint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:tinyint_col, type:tinyint, comment:null), ] +PREHOOK: query: SELECT COUNT(smallint_col), MIN(smallint_col) AS col, MAX(smallint_col), SUM(smallint_col) FROM commontypesagg GROUP BY (smallint_col) ORDER BY col +PREHOOK: type: QUERY +PREHOOK: Input: default@commontypesagg +#### A masked pattern was here #### +POSTHOOK: query: SELECT COUNT(smallint_col), MIN(smallint_col) AS col, MAX(smallint_col), SUM(smallint_col) FROM commontypesagg GROUP BY (smallint_col) ORDER BY col +POSTHOOK: type: QUERY +POSTHOOK: Input: default@commontypesagg +#### A masked pattern was here #### +POSTHOOK: Lineage: commontypesagg.bigint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bigint_col, type:bigint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.bool_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bool_col, type:boolean, comment:null), ] +POSTHOOK: Lineage: commontypesagg.date_string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:date_string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.double_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:double_col, type:double, comment:null), ] +POSTHOOK: Lineage: commontypesagg.float_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:float_col, type:float, comment:null), ] +POSTHOOK: Lineage: commontypesagg.id SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:id, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.int_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:int_col, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.smallint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:smallint_col, type:smallint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.tinyint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:tinyint_col, type:tinyint, comment:null), ] +0 NULL NULL NULL +1 1 1 1 +1 2 2 2 +1 3 3 3 +1 4 4 4 +1 5 5 5 +1 6 6 6 +1 7 7 7 +1 8 8 8 +1 9 9 9 +1 10 10 10 +1 11 11 11 +1 12 12 12 +1 13 13 13 +1 14 14 14 +1 15 15 15 +1 16 16 16 +1 17 17 17 +1 18 18 18 +1 19 19 19 +1 20 20 20 +1 21 21 21 +1 22 22 22 +1 23 23 23 +1 24 24 24 +1 25 25 25 +1 26 26 26 +1 27 27 27 +1 28 28 28 +1 29 29 29 +1 30 30 30 +1 31 31 31 +1 32 32 32 +1 33 33 33 +1 34 34 34 +1 35 35 35 +1 36 36 36 +1 37 37 37 +1 38 38 38 +1 39 39 39 +1 40 40 40 +1 41 41 41 +1 42 42 42 +1 43 43 43 +1 44 44 44 +1 45 45 45 +1 46 46 46 +1 47 47 47 +1 48 48 48 +1 49 49 49 +1 50 50 50 +1 51 51 51 +1 52 52 52 +1 53 53 53 +1 54 54 54 +1 55 55 55 +1 56 56 56 +1 57 57 57 +1 58 58 58 +1 59 59 59 +1 60 60 60 +1 61 61 61 +1 62 62 62 +1 63 63 63 +1 64 64 64 +1 65 65 65 +1 66 66 66 +1 67 67 67 +1 68 68 68 +1 69 69 69 +1 70 70 70 +1 71 71 71 +1 72 72 72 +1 73 73 73 +1 74 74 74 +1 75 75 75 +1 76 76 76 +1 77 77 77 +1 78 78 78 +1 79 79 79 +1 80 80 80 +1 81 81 81 +1 82 82 82 +1 83 83 83 +1 84 84 84 +1 85 85 85 +1 86 86 86 +1 87 87 87 +1 88 88 88 +1 89 89 89 +1 90 90 90 +1 91 91 91 +1 92 92 92 +1 93 93 93 +1 94 94 94 +1 95 95 95 +1 96 96 96 +1 97 97 97 +1 98 98 98 +1 99 99 99 +PREHOOK: query: SELECT COUNT(tinyint_col), MIN(tinyint_col) AS col, MAX(tinyint_col), SUM(tinyint_col) FROM commontypesagg GROUP BY (tinyint_col) ORDER BY col +PREHOOK: type: QUERY +PREHOOK: Input: default@commontypesagg +#### A masked pattern was here #### +POSTHOOK: query: SELECT COUNT(tinyint_col), MIN(tinyint_col) AS col, MAX(tinyint_col), SUM(tinyint_col) FROM commontypesagg GROUP BY (tinyint_col) ORDER BY col +POSTHOOK: type: QUERY +POSTHOOK: Input: default@commontypesagg +#### A masked pattern was here #### +POSTHOOK: Lineage: commontypesagg.bigint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bigint_col, type:bigint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.bool_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:bool_col, type:boolean, comment:null), ] +POSTHOOK: Lineage: commontypesagg.date_string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:date_string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.double_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:double_col, type:double, comment:null), ] +POSTHOOK: Lineage: commontypesagg.float_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:float_col, type:float, comment:null), ] +POSTHOOK: Lineage: commontypesagg.id SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:id, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.int_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:int_col, type:int, comment:null), ] +POSTHOOK: Lineage: commontypesagg.smallint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:smallint_col, type:smallint, comment:null), ] +POSTHOOK: Lineage: commontypesagg.string_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:string_col, type:string, comment:null), ] +POSTHOOK: Lineage: commontypesagg.tinyint_col SIMPLE [(alltypesagg)alltypesagg.FieldSchema(name:tinyint_col, type:tinyint, comment:null), ] +0 NULL NULL NULL +10 1 1 10 +10 2 2 20 +10 3 3 30 +10 4 4 40 +10 5 5 50 +10 6 6 60 +10 7 7 70 +10 8 8 80 +10 9 9 90