Repository: hive Updated Branches: refs/heads/master a3f0f99d5 -> acc6fa262
http://git-wip-us.apache.org/repos/asf/hive/blob/acc6fa26/ql/src/test/results/clientpositive/druid/druidmini_test1.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/druid/druidmini_test1.q.out b/ql/src/test/results/clientpositive/druid/druidmini_test1.q.out index 6f85515..e0feb41 100644 --- a/ql/src/test/results/clientpositive/druid/druidmini_test1.q.out +++ b/ql/src/test/results/clientpositive/druid/druidmini_test1.q.out @@ -1,57 +1,6 @@ -PREHOOK: query: CREATE EXTERNAL TABLE druid_table_n3 -STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler' -TBLPROPERTIES ("druid.segment.granularity" = "HOUR", "druid.query.granularity" = "MINUTE") -AS -SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`, - cstring1, - cstring2, - cdouble, - cfloat, - ctinyint, - csmallint, - cint, - cbigint, - cboolean1, - cboolean2 - FROM alltypesorc where ctimestamp1 IS NOT NULL -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@alltypesorc -PREHOOK: Output: database:default -PREHOOK: Output: default@druid_table_n3 -POSTHOOK: query: CREATE EXTERNAL TABLE druid_table_n3 -STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler' -TBLPROPERTIES ("druid.segment.granularity" = "HOUR", "druid.query.granularity" = "MINUTE") -AS -SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`, - cstring1, - cstring2, - cdouble, - cfloat, - ctinyint, - csmallint, - cint, - cbigint, - cboolean1, - cboolean2 - FROM alltypesorc where ctimestamp1 IS NOT NULL -POSTHOOK: type: CREATETABLE_AS_SELECT -POSTHOOK: Input: default@alltypesorc -POSTHOOK: Output: database:default -POSTHOOK: Output: default@druid_table_n3 -POSTHOOK: Lineage: druid_table_n3.__time EXPRESSION [(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cbigint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cboolean1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cboolean2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cdouble SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cfloat SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.csmallint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cstring1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.cstring2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string, comment:null), ] -POSTHOOK: Lineage: druid_table_n3.ctinyint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint, comment:null), ] -PREHOOK: query: explain select count(*) FROM druid_table_n3 +PREHOOK: query: explain select count(*) FROM druid_table_alltypesorc PREHOOK: type: QUERY -POSTHOOK: query: explain select count(*) FROM druid_table_n3 +POSTHOOK: query: explain select count(*) FROM druid_table_alltypesorc POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -62,31 +11,31 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames $f0 druid.fieldTypes bigint - druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_n3","descending":false,"granularity":"all","aggregations":[{"type":"count","name":"$f0"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":false}} + druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_alltypesorc","descending":false,"granularity":"all","aggregations":[{"type":"count","name":"$f0"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":false}} druid.query.type timeseries Select Operator expressions: $f0 (type: bigint) outputColumnNames: _col0 ListSink -PREHOOK: query: SELECT count(*) FROM druid_table_n3 +PREHOOK: query: SELECT count(*) FROM druid_table_alltypesorc PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT count(*) FROM druid_table_n3 +POSTHOOK: query: SELECT count(*) FROM druid_table_alltypesorc POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 6105 PREHOOK: query: EXPLAIN SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -97,11 +46,11 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames timestamp,$f1,$f2,$f3,$f4,$f5,$f6 druid.fieldTypes timestamp with local time zone,double,double,bigint,bigint,bigint,bigint - druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_n3","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"},{"type":"doubleSum","name":"$f2","fieldName":"cdouble"},{"type":"longSum","name":"$f3","fieldName":"ctinyint"},{"type":"longSum","name":"$f4","fieldName":"csmallint"},{"type":"longSum","name":"$f5","fieldName":"cint"},{"type":"longSum","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} + druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_alltypesorc","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"},{"type":"doubleSum","name":"$f2","fieldName":"cdouble"},{"type":"longSum","name":"$f3","fieldName":"ctinyint"},{"type":"longSum","name":"$f4","fieldName":"csmallint"},{"type":"longSum","name":"$f5","fieldName":"cint"},{"type":"longSum","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} druid.query.type timeseries Select Operator expressions: timestamp (type: timestamp with local time zone), $f1 (type: double), $f2 (type: double), $f3 (type: bigint), $f4 (type: bigint), $f5 (type: bigint), $f6 (type: bigint) @@ -109,21 +58,21 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-01-01 00:00:00.0 US/Pacific -39590.24724686146 2.7308662809692383E7 -39967 7781089 1408069801800 10992545287 PREHOOK: query: EXPLAIN SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -134,11 +83,11 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames timestamp,$f1,$f2,$f3,$f4,$f5,$f6 druid.fieldTypes timestamp with local time zone,float,double,tinyint,smallint,int,bigint - druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_n3","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleMin","name":"$f1","fieldName":"cfloat"},{"type":"doubleMin","name":"$f2","fieldName":"cdouble"},{"type":"longMin","name":"$f3","fieldName":"ctinyint"},{"type":"longMin","name":"$f4","fieldName":"csmallint"},{"type":"longMin","name":"$f5","fieldName":"cint"},{"type":"longMin","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} + druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_alltypesorc","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleMin","name":"$f1","fieldName":"cfloat"},{"type":"doubleMin","name":"$f2","fieldName":"cdouble"},{"type":"longMin","name":"$f3","fieldName":"ctinyint"},{"type":"longMin","name":"$f4","fieldName":"csmallint"},{"type":"longMin","name":"$f5","fieldName":"cint"},{"type":"longMin","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} druid.query.type timeseries Select Operator expressions: timestamp (type: timestamp with local time zone), $f1 (type: float), $f2 (type: double), $f3 (type: tinyint), $f4 (type: smallint), $f5 (type: int), $f6 (type: bigint) @@ -146,21 +95,21 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-01-01 00:00:00.0 US/Pacific -1790.7781 -308691.84375 2 14255 -1073279343 -8577981133 PREHOOK: query: EXPLAIN SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -171,11 +120,11 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames timestamp,$f1,$f2,$f3,$f4,$f5,$f6 druid.fieldTypes timestamp with local time zone,float,double,tinyint,smallint,int,bigint - druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_n3","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleMax","name":"$f1","fieldName":"cfloat"},{"type":"doubleMax","name":"$f2","fieldName":"cdouble"},{"type":"longMax","name":"$f3","fieldName":"ctinyint"},{"type":"longMax","name":"$f4","fieldName":"csmallint"},{"type":"longMax","name":"$f5","fieldName":"cint"},{"type":"longMax","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} + druid.query.json {"queryType":"timeseries","dataSource":"default.druid_table_alltypesorc","descending":false,"granularity":{"type":"period","period":"P1Y","timeZone":"US/Pacific"},"aggregations":[{"type":"doubleMax","name":"$f1","fieldName":"cfloat"},{"type":"doubleMax","name":"$f2","fieldName":"cdouble"},{"type":"longMax","name":"$f3","fieldName":"ctinyint"},{"type":"longMax","name":"$f4","fieldName":"csmallint"},{"type":"longMax","name":"$f5","fieldName":"cint"},{"type":"longMax","name":"$f6","fieldName":"cbigint"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"context":{"skipEmptyBuckets":true}} druid.query.type timeseries Select Operator expressions: timestamp (type: timestamp with local time zone), $f1 (type: float), $f2 (type: double), $f3 (type: tinyint), $f4 (type: smallint), $f5 (type: int), $f6 (type: bigint) @@ -183,19 +132,19 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_n3 GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-01-01 00:00:00.0 US/Pacific 769.16394 1.9565518E7 -45 -8101 1276572707 4923772860 -PREHOOK: query: EXPLAIN SELECT cstring1, SUM(cdouble) as s FROM druid_table_n3 GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +PREHOOK: query: EXPLAIN SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT cstring1, SUM(cdouble) as s FROM druid_table_n3 GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +POSTHOOK: query: EXPLAIN SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -206,24 +155,24 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames cstring1,$f1 druid.fieldTypes string,double - druid.query.json {"queryType":"groupBy","dataSource":"default.druid_table_n3","granularity":"all","dimensions":[{"type":"default","dimension":"cstring1","outputName":"cstring1","outputType":"STRING"}],"limitSpec":{"type":"default","limit":10,"columns":[{"dimension":"$f1","direction":"ascending","dimensionOrder":"numeric"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cdouble"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]} + druid.query.json {"queryType":"groupBy","dataSource":"default.druid_table_alltypesorc","granularity":"all","dimensions":[{"type":"default","dimension":"cstring1","outputName":"cstring1","outputType":"STRING"}],"limitSpec":{"type":"default","limit":10,"columns":[{"dimension":"$f1","direction":"ascending","dimensionOrder":"numeric"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cdouble"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]} druid.query.type groupBy Select Operator expressions: cstring1 (type: string), $f1 (type: double) outputColumnNames: _col0, _col1 ListSink -PREHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_n3 GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +PREHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_n3 GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +POSTHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1cGVWH7n1QU -596096.6875 821UdmGbkEf4j -14161.827026367188 @@ -235,9 +184,9 @@ yv1js 0.0 02vDyIVT752 0.0 00PafC7v 0.0 ytpx1RL8F2I 0.0 -PREHOOK: query: EXPLAIN SELECT cstring2, MAX(cdouble) FROM druid_table_n3 GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +PREHOOK: query: EXPLAIN SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT cstring2, MAX(cdouble) FROM druid_table_n3 GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +POSTHOOK: query: EXPLAIN SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -248,24 +197,24 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames cstring2,$f1 druid.fieldTypes string,double - druid.query.json {"queryType":"groupBy","dataSource":"default.druid_table_n3","granularity":"all","dimensions":[{"type":"default","dimension":"cstring2","outputName":"cstring2","outputType":"STRING"}],"limitSpec":{"type":"default","limit":10,"columns":[{"dimension":"cstring2","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleMax","name":"$f1","fieldName":"cdouble"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]} + druid.query.json {"queryType":"groupBy","dataSource":"default.druid_table_alltypesorc","granularity":"all","dimensions":[{"type":"default","dimension":"cstring2","outputName":"cstring2","outputType":"STRING"}],"limitSpec":{"type":"default","limit":10,"columns":[{"dimension":"cstring2","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleMax","name":"$f1","fieldName":"cdouble"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]} druid.query.type groupBy Select Operator expressions: cstring2 (type: string), $f1 (type: double) outputColumnNames: _col0, _col1 ListSink -PREHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_n3 GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +PREHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_n3 GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +POSTHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### NULL 1.9565518E7 0034fkcXMQI3 15601.0 @@ -279,11 +228,11 @@ NULL 1.9565518E7 01EfkvNk6mjG44uxs 0.0 PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -300,11 +249,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -343,14 +292,14 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -364,12 +313,12 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -387,11 +336,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1900-01-01T00:00:00.000Z/1970-03-01T08:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/1970-03-01T08:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -430,16 +379,16 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -453,12 +402,12 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -476,11 +425,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1968-01-01T08:00:00.000Z/1970-03-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1968-01-01T08:00:00.000Z/1970-03-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -519,16 +468,16 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -542,13 +491,13 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY @@ -567,11 +516,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1968-01-01T08:00:00.000Z/1970-03-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1968-01-01T08:00:00.000Z/1970-03-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -610,18 +559,18 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -635,12 +584,12 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -658,11 +607,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1968-01-01T08:00:00.000Z/1970-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1968-01-01T08:00:00.000Z/1970-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -701,16 +650,16 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -724,13 +673,13 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY @@ -749,11 +698,11 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes timestamp with local time zone - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1968-01-01T08:00:00.000Z/1970-04-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1968-01-01T08:00:00.000Z/1970-04-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Statistics: Num rows: 9173 Data size: 348640 Basic stats: COMPLETE Column stats: NONE Select Operator @@ -792,18 +741,18 @@ STAGE PLANS: ListSink PREHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_n3 +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific @@ -815,9 +764,9 @@ POSTHOOK: Output: hdfs://### HDFS PATH ### 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific 1969-12-31 15:59:00.0 US/Pacific -PREHOOK: query: explain select (cstring1 is null ) AS is_null, (cint is not null ) as isnotnull FROM druid_table_n3 +PREHOOK: query: explain select (cstring1 is null ) AS is_null, (cint is not null ) as isnotnull FROM druid_table_alltypesorc PREHOOK: type: QUERY -POSTHOOK: query: explain select (cstring1 is null ) AS is_null, (cint is not null ) as isnotnull FROM druid_table_n3 +POSTHOOK: query: explain select (cstring1 is null ) AS is_null, (cint is not null ) as isnotnull FROM druid_table_alltypesorc POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -828,20 +777,20 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc,vc0 druid.fieldTypes boolean,boolean - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"isnull(\"cstring1\")","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"notnull(\"cint\")","outputType":"LONG"}],"columns":["vc","vc0"],"resultFormat":"compactedList"} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"isnull(\"cstring1\")","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"notnull(\"cint\")","outputType":"LONG"}],"columns":["vc","vc0"],"resultFormat":"compactedList"} druid.query.type scan Select Operator expressions: vc (type: boolean), vc0 (type: boolean) outputColumnNames: _col0, _col1 ListSink -PREHOOK: query: explain select substring(to_date(`__time`), 4) from druid_table_n3 limit 5 +PREHOOK: query: explain select substring(to_date(`__time`), 4) from druid_table_alltypesorc limit 5 PREHOOK: type: QUERY -POSTHOOK: query: explain select substring(to_date(`__time`), 4) from druid_table_n3 limit 5 +POSTHOOK: query: explain select substring(to_date(`__time`), 4) from druid_table_alltypesorc limit 5 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -852,33 +801,33 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes string - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"substring(timestamp_format(timestamp_floor(\"__time\",'P1D','','US/Pacific'),'yyyy-MM-dd','UTC'), 3, -1)","outputType":"STRING"}],"columns":["vc"],"resultFormat":"compactedList","limit":5} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"substring(timestamp_format(timestamp_floor(\"__time\",'P1D','','US/Pacific'),'yyyy-MM-dd','UTC'), 3, -1)","outputType":"STRING"}],"columns":["vc"],"resultFormat":"compactedList","limit":5} druid.query.type scan Select Operator expressions: vc (type: string) outputColumnNames: _col0 ListSink -PREHOOK: query: select substring(to_date(`__time`), 4) from druid_table_n3 limit 5 +PREHOOK: query: select substring(to_date(`__time`), 4) from druid_table_alltypesorc limit 5 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: select substring(to_date(`__time`), 4) from druid_table_n3 limit 5 +POSTHOOK: query: select substring(to_date(`__time`), 4) from druid_table_alltypesorc limit 5 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 9-12-31 9-12-31 9-12-31 9-12-31 9-12-31 -PREHOOK: query: explain select substring(cast(to_date(`__time`) as string), 4) from druid_table_n3 limit 5 +PREHOOK: query: explain select substring(cast(to_date(`__time`) as string), 4) from druid_table_alltypesorc limit 5 PREHOOK: type: QUERY -POSTHOOK: query: explain select substring(cast(to_date(`__time`) as string), 4) from druid_table_n3 limit 5 +POSTHOOK: query: explain select substring(cast(to_date(`__time`) as string), 4) from druid_table_alltypesorc limit 5 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -889,24 +838,24 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_n3 + alias: druid_table_alltypesorc properties: druid.fieldNames vc druid.fieldTypes string - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_n3","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"substring(timestamp_format(timestamp_floor(\"__time\",'P1D','','US/Pacific'),'yyyy-MM-dd','UTC'), 3, -1)","outputType":"STRING"}],"columns":["vc"],"resultFormat":"compactedList","limit":5} + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"substring(timestamp_format(timestamp_floor(\"__time\",'P1D','','US/Pacific'),'yyyy-MM-dd','UTC'), 3, -1)","outputType":"STRING"}],"columns":["vc"],"resultFormat":"compactedList","limit":5} druid.query.type scan Select Operator expressions: vc (type: string) outputColumnNames: _col0 ListSink -PREHOOK: query: select substring(cast(to_date(`__time`) as string), 4) from druid_table_n3 limit 5 +PREHOOK: query: select substring(cast(to_date(`__time`) as string), 4) from druid_table_alltypesorc limit 5 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_n3 +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: select substring(cast(to_date(`__time`) as string), 4) from druid_table_n3 limit 5 +POSTHOOK: query: select substring(cast(to_date(`__time`) as string), 4) from druid_table_alltypesorc limit 5 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_n3 +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 9-12-31 9-12-31 http://git-wip-us.apache.org/repos/asf/hive/blob/acc6fa26/ql/src/test/results/clientpositive/druid/druidmini_test_ts.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/druid/druidmini_test_ts.q.out b/ql/src/test/results/clientpositive/druid/druidmini_test_ts.q.out index a8e6894..9c624c2 100644 --- a/ql/src/test/results/clientpositive/druid/druidmini_test_ts.q.out +++ b/ql/src/test/results/clientpositive/druid/druidmini_test_ts.q.out @@ -1,103 +1,52 @@ -PREHOOK: query: CREATE TABLE druid_table_test_ts -STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler' -TBLPROPERTIES ("druid.segment.granularity" = "HOUR", "druid.query.granularity" = "MINUTE") -AS -SELECT `ctimestamp1` as `__time`, - cstring1, - cstring2, - cdouble, - cfloat, - ctinyint, - csmallint, - cint, - cbigint, - cboolean1, - cboolean2 - FROM alltypesorc where ctimestamp1 IS NOT NULL -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@alltypesorc -PREHOOK: Output: database:default -PREHOOK: Output: default@druid_table_test_ts -POSTHOOK: query: CREATE TABLE druid_table_test_ts -STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler' -TBLPROPERTIES ("druid.segment.granularity" = "HOUR", "druid.query.granularity" = "MINUTE") -AS -SELECT `ctimestamp1` as `__time`, - cstring1, - cstring2, - cdouble, - cfloat, - ctinyint, - csmallint, - cint, - cbigint, - cboolean1, - cboolean2 - FROM alltypesorc where ctimestamp1 IS NOT NULL -POSTHOOK: type: CREATETABLE_AS_SELECT -POSTHOOK: Input: default@alltypesorc -POSTHOOK: Output: database:default -POSTHOOK: Output: default@druid_table_test_ts -POSTHOOK: Lineage: druid_table_test_ts.__time SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cbigint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cboolean1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cboolean2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cdouble SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cfloat SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.csmallint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cstring1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.cstring2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string, comment:null), ] -POSTHOOK: Lineage: druid_table_test_ts.ctinyint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint, comment:null), ] -PREHOOK: query: SELECT count(*) FROM druid_table_test_ts +PREHOOK: query: SELECT count(*) FROM druid_table_alltypesorc PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT count(*) FROM druid_table_test_ts +POSTHOOK: query: SELECT count(*) FROM druid_table_alltypesorc POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 6105 PREHOOK: query: SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), SUM(cfloat), SUM(cdouble), SUM(ctinyint), SUM(csmallint),SUM(cint), SUM(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-01-01 00:00:00 -39590.24724686146 2.7308662809692383E7 -39967 7781089 1408069801800 10992545287 +1969-01-01 00:00:00.0 US/Pacific -39590.24724686146 2.7308662809692383E7 -39967 7781089 1408069801800 10992545287 PREHOOK: query: SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), MIN(cfloat), MIN(cdouble), MIN(ctinyint), MIN(csmallint),MIN(cint), MIN(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-01-01 00:00:00 -1790.7781 -308691.84375 2 14255 -1073279343 -8577981133 +1969-01-01 00:00:00.0 US/Pacific -1790.7781 -308691.84375 2 14255 -1073279343 -8577981133 PREHOOK: query: SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT floor_year(`__time`), MAX(cfloat), MAX(cdouble), MAX(ctinyint), MAX(csmallint),MAX(cint), MAX(cbigint) -FROM druid_table_test_ts GROUP BY floor_year(`__time`) +FROM druid_table_alltypesorc GROUP BY floor_year(`__time`) POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-01-01 00:00:00 769.16394 1.9565518E7 -45 -8101 1276572707 4923772860 -PREHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_test_ts GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +1969-01-01 00:00:00.0 US/Pacific 769.16394 1.9565518E7 -45 -8101 1276572707 4923772860 +PREHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_test_ts GROUP BY cstring1 ORDER BY s ASC LIMIT 10 +POSTHOOK: query: SELECT cstring1, SUM(cdouble) as s FROM druid_table_alltypesorc GROUP BY cstring1 ORDER BY s ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### 1cGVWH7n1QU -596096.6875 821UdmGbkEf4j -14161.827026367188 @@ -109,13 +58,13 @@ yv1js 0.0 02vDyIVT752 0.0 00PafC7v 0.0 ytpx1RL8F2I 0.0 -PREHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_test_ts GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +PREHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### -POSTHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_test_ts GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 +POSTHOOK: query: SELECT cstring2, MAX(cdouble) FROM druid_table_alltypesorc GROUP BY cstring2 ORDER BY cstring2 ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### NULL 1.9565518E7 0034fkcXMQI3 15601.0 @@ -128,146 +77,146 @@ NULL 1.9565518E7 017fFeQ3Gcsa83Xj2Vo0 0.0 01EfkvNk6mjG44uxs 0.0 PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts ORDER BY `__time` ASC LIMIT 10 +FROM druid_table_alltypesorc ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` < '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '1968-01-01 00:00:00' AND `__time` <= '1970-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00' ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 PREHOOK: type: QUERY -PREHOOK: Input: default@druid_table_test_ts +PREHOOK: Input: default@druid_table_alltypesorc PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '1968-01-01 00:00:00' AND '1970-01-01 00:00:00') OR (`__time` BETWEEN '1968-02-01 00:00:00' AND '1970-04-01 00:00:00') ORDER BY `__time` ASC LIMIT 10 POSTHOOK: type: QUERY -POSTHOOK: Input: default@druid_table_test_ts +POSTHOOK: Input: default@druid_table_alltypesorc POSTHOOK: Output: hdfs://### HDFS PATH ### -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 -1969-12-31 15:59:00 +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific +1969-12-31 15:59:00.0 US/Pacific PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-0 is a root stage @@ -278,25 +227,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` < '2012-03-01 00:00:00' PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` < '2012-03-01 00:00:00' POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -308,25 +257,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["1900-01-01T00:00:00.000Z/2012-03-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/2012-03-01T08:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '2010-01-01 00:00:00' AND `__time` <= '2012-03-01 00:00:00' PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '2010-01-01 00:00:00' AND `__time` <= '2012-03-01 00:00:00' POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -338,26 +287,26 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2012-03-01T00:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2012-03-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '2010-01-01 00:00:00' AND `__time` <= '2012-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` >= '2010-01-01 00:00:00' AND `__time` <= '2012-03-01 00:00:00' AND `__time` < '2011-01-01 00:00:00' POSTHOOK: type: QUERY @@ -370,25 +319,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2011-01-01T00:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2011-01-01T08:00:00.000Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00' PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00' POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -400,26 +349,26 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2011-01-01T00:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2011-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00') OR (`__time` BETWEEN '2012-01-01 00:00:00' AND '2013-01-01 00:00:00') PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00') OR (`__time` BETWEEN '2012-01-01 00:00:00' AND '2013-01-01 00:00:00') POSTHOOK: type: QUERY @@ -432,26 +381,26 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2011-01-01T00:00:00.001Z","2012-01-01T00:00:00.000Z/2013-01-01T00:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2011-01-01T08:00:00.001Z","2012-01-01T08:00:00.000Z/2013-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00') OR (`__time` BETWEEN '2010-06-01 00:00:00' AND '2012-01-01 00:00:00') PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE (`__time` BETWEEN '2010-01-01 00:00:00' AND '2011-01-01 00:00:00') OR (`__time` BETWEEN '2010-06-01 00:00:00' AND '2012-01-01 00:00:00') POSTHOOK: type: QUERY @@ -464,25 +413,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2012-01-01T00:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2012-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time` -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -494,25 +443,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc - druid.fieldTypes timestamp - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2010-01-01T00:00:00.001Z","2011-01-01T00:00:00.000Z/2011-01-01T00:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2010-01-01T08:00:00.001Z","2011-01-01T08:00:00.000Z/2011-01-01T08:00:00.001Z"],"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp) + expressions: vc (type: timestamp with local time zone) outputColumnNames: _col0 ListSink PREHOOK: query: EXPLAIN SELECT `__time`, cstring2 -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE cstring2 = 'user1' AND `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time`, cstring2 -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE cstring2 = 'user1' AND `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -524,25 +473,25 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc,vc0 - druid.fieldTypes timestamp,string - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["2010-01-01T00:00:00.000Z/2010-01-01T00:00:00.001Z","2011-01-01T00:00:00.000Z/2011-01-01T00:00:00.001Z"],"filter":{"type":"selector","dimension":"cstring2","value":"user1"},"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"'user1'","outputType":"STRING"}],"columns":["vc","vc0"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone,string + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["2010-01-01T08:00:00.000Z/2010-01-01T08:00:00.001Z","2011-01-01T08:00:00.000Z/2011-01-01T08:00:00.001Z"],"filter":{"type":"selector","dimension":"cstring2","value":"user1"},"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"'user1'","outputType":"STRING"}],"columns":["vc","vc0"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp), vc0 (type: string) + expressions: vc (type: timestamp with local time zone), vc0 (type: string) outputColumnNames: _col0, _col1 ListSink PREHOOK: query: EXPLAIN SELECT `__time`, cstring2 -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE cstring2 = 'user1' OR `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') PREHOOK: type: QUERY POSTHOOK: query: EXPLAIN SELECT `__time`, cstring2 -FROM druid_table_test_ts +FROM druid_table_alltypesorc WHERE cstring2 = 'user1' OR `__time` IN ('2010-01-01 00:00:00','2011-01-01 00:00:00') POSTHOOK: type: QUERY STAGE DEPENDENCIES: @@ -554,14 +503,14 @@ STAGE PLANS: limit: -1 Processor Tree: TableScan - alias: druid_table_test_ts + alias: druid_table_alltypesorc properties: druid.fieldNames vc,cstring2 - druid.fieldTypes timestamp,string - druid.query.json {"queryType":"scan","dataSource":"default.druid_table_test_ts","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"or","fields":[{"type":"selector","dimension":"cstring2","value":"user1"},{"type":"selector","dimension":"__time","value":"2010-01-01T00:00:00.000Z","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'","timeZone":"UTC"}},{"type":"selector","dimension":"__time","value":"2011-01-01T00:00:00.000Z","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'","timeZone":"UTC"}}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc","cstring2"],"resultFormat":"compactedList"} + druid.fieldTypes timestamp with local time zone,string + druid.query.json {"queryType":"scan","dataSource":"default.druid_table_alltypesorc","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"or","fields":[{"type":"selector","dimension":"cstring2","value":"user1"},{"type":"selector","dimension":"__time","value":"2010-01-01T08:00:00.000Z","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'","timeZone":"UTC"}},{"type":"selector","dimension":"__time","value":"2011-01-01T08:00:00.000Z","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'","timeZone":"UTC"}}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"\"__time\"","outputType":"LONG"}],"columns":["vc","cstring2"],"resultFormat":"compactedList"} druid.query.type scan Select Operator - expressions: vc (type: timestamp), cstring2 (type: string) + expressions: vc (type: timestamp with local time zone), cstring2 (type: string) outputColumnNames: _col0, _col1 ListSink
