http://git-wip-us.apache.org/repos/asf/hive/blob/acc6fa26/ql/src/test/results/clientpositive/druid/druidmini_extractTime.q.out
----------------------------------------------------------------------
diff --git
a/ql/src/test/results/clientpositive/druid/druidmini_extractTime.q.out
b/ql/src/test/results/clientpositive/druid/druidmini_extractTime.q.out
index a7fb6c5..6090472 100644
--- a/ql/src/test/results/clientpositive/druid/druidmini_extractTime.q.out
+++ b/ql/src/test/results/clientpositive/druid/druidmini_extractTime.q.out
@@ -1,72 +1,21 @@
-PREHOOK: query: CREATE EXTERNAL TABLE druid_table
-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
-POSTHOOK: query: CREATE EXTERNAL TABLE druid_table
-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
-POSTHOOK: Lineage: druid_table.__time EXPRESSION
[(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp,
comment:null), ]
-POSTHOOK: Lineage: druid_table.cbigint SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null),
]
-POSTHOOK: Lineage: druid_table.cboolean1 SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean,
comment:null), ]
-POSTHOOK: Lineage: druid_table.cboolean2 SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean,
comment:null), ]
-POSTHOOK: Lineage: druid_table.cdouble SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null),
]
-POSTHOOK: Lineage: druid_table.cfloat SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ]
-POSTHOOK: Lineage: druid_table.cint SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ]
-POSTHOOK: Lineage: druid_table.csmallint SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint,
comment:null), ]
-POSTHOOK: Lineage: druid_table.cstring1 SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string,
comment:null), ]
-POSTHOOK: Lineage: druid_table.cstring2 SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string,
comment:null), ]
-POSTHOOK: Lineage: druid_table.ctinyint SIMPLE
[(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint,
comment:null), ]
-PREHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(SECOND from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(SECOND from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
0
-PREHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(SECOND from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(SECOND from `__time`)
POSTHOOK: type: QUERY
@@ -79,36 +28,36 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_second
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_second","extractionFn":{"type":"timeFormat","format":"s","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_second","extractionFn":{"type":"timeFormat","format":"s","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_second (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MINUTE from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MINUTE from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
0
59
-PREHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MINUTE from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MINUTE from `__time`)
POSTHOOK: type: QUERY
@@ -121,36 +70,36 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_minute
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_minute","extractionFn":{"type":"timeFormat","format":"m","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_minute","extractionFn":{"type":"timeFormat","format":"m","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_minute (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(HOUR from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(HOUR from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
15
16
-PREHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(HOUR from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(HOUR from `__time`)
POSTHOOK: type: QUERY
@@ -163,35 +112,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_hour
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_hour","extractionFn":{"type":"timeFormat","format":"H","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_hour","extractionFn":{"type":"timeFormat","format":"H","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_hour (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(DAY from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(DAY from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(DAY from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(DAY from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(DAY from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(DAY from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
31
-PREHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(DAY from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(DAY from `__time`)
POSTHOOK: type: QUERY
@@ -204,35 +153,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_day
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_day","extractionFn":{"type":"timeFormat","format":"d","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_day","extractionFn":{"type":"timeFormat","format":"d","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_day (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(WEEK from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(WEEK from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1
-PREHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(WEEK from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(WEEK from `__time`)
POSTHOOK: type: QUERY
@@ -245,35 +194,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_week
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_week","extractionFn":{"type":"timeFormat","format":"w","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_week","extractionFn":{"type":"timeFormat","format":"w","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_week (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(MONTH from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(MONTH from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MONTH from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(MONTH from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(MONTH from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MONTH from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
12
-PREHOOK: query: EXPLAIN SELECT EXTRACT(MONTH from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(MONTH from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MONTH from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(MONTH from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(MONTH from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(MONTH from `__time`)
POSTHOOK: type: QUERY
@@ -286,35 +235,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_month
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_month","extractionFn":{"type":"timeFormat","format":"M","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_month","extractionFn":{"type":"timeFormat","format":"M","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_month (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(QUARTER from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(QUARTER from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(QUARTER from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(QUARTER from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(QUARTER from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(QUARTER from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
4
-PREHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(QUARTER from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(QUARTER from `__time`)
POSTHOOK: type: QUERY
@@ -327,35 +276,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"default","dimension":"vc","outputName":"vc","outputType":"LONG"}],"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'QUARTER','US/Pacific')","outputType":"LONG"}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"vc","outputName":"vc","outputType":"LONG"}],"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'QUARTER','US/Pacific')","outputType":"LONG"}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: vc (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(YEAR from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(YEAR from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(YEAR from `__time`)
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(YEAR from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(YEAR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(YEAR from `__time`)
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1969
-PREHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(YEAR from `__time`)
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 GROUP
BY EXTRACT(YEAR from `__time`)
POSTHOOK: type: QUERY
@@ -368,20 +317,20 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract_year
druid.fieldTypes int
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract_year","extractionFn":{"type":"timeFormat","format":"yyyy","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"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":"extraction","dimension":"__time","outputName":"extract_year","extractionFn":{"type":"timeFormat","format":"yyyy","timeZone":"US/Pacific","locale":"en-US"}}],"limitSpec":{"type":"default"},"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"aggregations":[],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract_year (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM druid_table
WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
+PREHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM druid_table
WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
Stage-0 is a root stage
@@ -392,30 +341,30 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc
druid.fieldTypes int
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"bound","dimension":"__time","lower":"0","lowerStrict":false,"upper":"0","upperStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"s","timeZone":"US/Pacific","locale":"en-US"}},"virtualColumns":[{"type":"expression","name":"vc","expression":"0","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
+ 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":"bound","dimension":"__time","lower":"0","lowerStrict":false,"upper":"0","upperStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"s","timeZone":"US/Pacific","locale":"en-US"}},"virtualColumns":[{"type":"expression","name":"vc","expression":"0","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM druid_table WHERE
EXTRACT(SECOND from `__time`) = 0 LIMIT 1
+PREHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM druid_table WHERE
EXTRACT(SECOND from `__time`) = 0 LIMIT 1
+POSTHOOK: query: SELECT EXTRACT(SECOND from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(SECOND from `__time`) = 0 LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
0
-PREHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE EXTRACT(MINUTE from `__time`) >= 0 LIMIT 2
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(MINUTE from `__time`) FROM
druid_table_alltypesorc
WHERE EXTRACT(MINUTE from `__time`) >= 0 LIMIT 2
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
@@ -427,34 +376,34 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc
druid.fieldTypes int
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"bound","dimension":"__time","lower":"0","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"m","timeZone":"US/Pacific","locale":"en-US"}},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'MINUTE','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":2}
+ 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":"bound","dimension":"__time","lower":"0","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"m","timeZone":"US/Pacific","locale":"en-US"}},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'MINUTE','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":2}
druid.query.type scan
Select Operator
expressions: vc (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(MINUTE from `__time`) as minute FROM druid_table
+PREHOOK: query: SELECT EXTRACT(MINUTE from `__time`) as minute FROM
druid_table_alltypesorc
WHERE EXTRACT(MINUTE from `__time`) >= 0 order by minute LIMIT 2
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(MINUTE from `__time`) as minute FROM
druid_table
+POSTHOOK: query: SELECT EXTRACT(MINUTE from `__time`) as minute FROM
druid_table_alltypesorc
WHERE EXTRACT(MINUTE from `__time`) >= 0 order by minute LIMIT 2
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
0
0
-PREHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 LIMIT
1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 LIMIT
1
POSTHOOK: type: QUERY
@@ -467,35 +416,35 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc
druid.fieldTypes int
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'HOUR','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
+ 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":"and","fields":[{"type":"expression","expression":"(strlen(CAST(\"ctinyint\",
'STRING')) >
1)"},{"type":"expression","expression":"(strlen(CAST(\"ctinyint\", 'STRING')) <
10)"},{"type":"expression","expression":"((pow(\"cfloat\",2) *
pow(\"csmallint\",3)) >
1)"},{"type":"expression","expression":"(sqrt(abs(\"ctinyint\")) >
3)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'HOUR','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+PREHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 LIMIT
1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(HOUR from `__time`) FROM
druid_table_alltypesorc
WHERE character_length(CAST(ctinyint AS STRING)) > 1 AND
char_length(CAST(ctinyint AS STRING)) < 10
AND power(cfloat, 2) * pow(csmallint, 3) > 1 AND SQRT(ABS(ctinyint)) > 3 LIMIT
1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
15
PREHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`), EXTRACT(DAY from
`__time`) DIV 7 AS WEEK, SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9,
2) AS day_str
-FROM druid_table WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9, 2)
= 31 LIMIT 1
+FROM druid_table_alltypesorc WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 9, 2) = 31 LIMIT 1
PREHOOK: type: QUERY
POSTHOOK: query: EXPLAIN SELECT EXTRACT(DAY from `__time`), EXTRACT(DAY from
`__time`) DIV 7 AS WEEK, SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9,
2) AS day_str
-FROM druid_table WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9, 2)
= 31 LIMIT 1
+FROM druid_table_alltypesorc WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 9, 2) = 31 LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
Stage-0 is a root stage
@@ -506,11 +455,11 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc,vc0,vc1
druid.fieldTypes int,bigint,string
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"expression","expression":"(CAST(substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
8, 2), 'DOUBLE') ==
31)"},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'DAY','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"div(timestamp_extract(\"__time\",'DAY','US/Pacific'),7)","outputType":"LONG"},{"type":"expression","name":"vc1","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
8, 2)","outputType":"STRING"}],"columns":["vc","vc0","v
c1"],"resultFormat":"compactedList","limit":1}
+ 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":"expression","expression":"(CAST(substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
8, 2), 'DOUBLE') ==
31)"},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'DAY','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"div(timestamp_extract(\"__time\",'DAY','US/Pacific'),7)","outputType":"LONG"},{"type":"expression","name":"vc1","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
8, 2)","outputType":"STRING"}],"columns":["
vc","vc0","vc1"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int), vc0 (type: bigint), vc1 (type: string)
@@ -518,20 +467,20 @@ STAGE PLANS:
ListSink
PREHOOK: query: SELECT EXTRACT(DAY from `__time`) , EXTRACT(DAY from `__time`)
DIV 7 AS WEEK, SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9, 2) AS
dar_str
-FROM druid_table WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9, 2)
= 31 LIMIT 1
+FROM druid_table_alltypesorc WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 9, 2) = 31 LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
POSTHOOK: query: SELECT EXTRACT(DAY from `__time`) , EXTRACT(DAY from
`__time`) DIV 7 AS WEEK, SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9,
2) AS dar_str
-FROM druid_table WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 9, 2)
= 31 LIMIT 1
+FROM druid_table_alltypesorc WHERE SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 9, 2) = 31 LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
31 4 31
-PREHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM druid_table
WHERE EXTRACT(WEEK from `__time`) >= 1
+PREHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(WEEK from `__time`) >= 1
AND EXTRACT(WEEK from `__time`) DIV 4 + 1 = 1 LIMIT 1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM druid_table
WHERE EXTRACT(WEEK from `__time`) >= 1
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(WEEK from `__time`) >= 1
AND EXTRACT(WEEK from `__time`) DIV 4 + 1 = 1 LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
@@ -543,32 +492,32 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc
druid.fieldTypes int
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"and","fields":[{"type":"bound","dimension":"__time","lower":"1","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"w","timeZone":"US/Pacific","locale":"en-US"}},{"type":"expression","expression":"((div(timestamp_extract(\"__time\",'WEEK','US/Pacific'),4)
+ 1) ==
1)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'WEEK','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
+ 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":"and","fields":[{"type":"bound","dimension":"__time","lower":"1","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"w","timeZone":"US/Pacific","locale":"en-US"}},{"type":"expression","expression":"((div(timestamp_extract(\"__time\",'WEEK','US/Pacific'),4)
+ 1) ==
1)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'WEEK','US/Pacific')","outputType":"LONG"}],"columns":["vc"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int)
outputColumnNames: _col0
ListSink
-PREHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM druid_table WHERE
EXTRACT(WEEK from `__time`) >= 1
+PREHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(WEEK from `__time`) >= 1
AND EXTRACT(WEEK from `__time`) DIV 4 + 1 = 1 LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM druid_table WHERE
EXTRACT(WEEK from `__time`) >= 1
+POSTHOOK: query: SELECT EXTRACT(WEEK from `__time`) FROM
druid_table_alltypesorc WHERE EXTRACT(WEEK from `__time`) >= 1
AND EXTRACT(WEEK from `__time`) DIV 4 + 1 = 1 LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1
-PREHOOK: query: EXPLAIN SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1,
EXTRACT(MONTH FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 6, 2) as month_str FROM druid_table
+PREHOOK: query: EXPLAIN SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1,
EXTRACT(MONTH FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 6, 2) as month_str FROM druid_table_alltypesorc
WHERE EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 AND EXTRACT(MONTH FROM
`__time`) BETWEEN 11 AND 12 LIMIT 1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1,
EXTRACT(MONTH FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 6, 2) as month_str FROM druid_table
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1,
EXTRACT(MONTH FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS
STRING), 6, 2) as month_str FROM druid_table_alltypesorc
WHERE EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 AND EXTRACT(MONTH FROM
`__time`) BETWEEN 11 AND 12 LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
@@ -580,32 +529,32 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc,vc0,vc1
druid.fieldTypes double,int,string
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"and","fields":[{"type":"expression","expression":"(((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / 4) + 1) ==
4)"},{"type":"bound","dimension":"__time","lower":"11","lowerStrict":false,"upper":"12","upperStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"M","timeZone":"US/Pacific","locale":"en-US"}}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / CAST(4, 'DOUBLE')) + CAST(1,
'DOUBLE'))","outputType":"DOUBLE"},{"type":"expression","name":"vc0","expression":"timestamp_extract(\"__time\",'MONTH','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc1","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u002
7T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
5,
2)","outputType":"STRING"}],"columns":["vc","vc0","vc1"],"resultFormat":"compactedList","limit":1}
+ 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":"and","fields":[{"type":"expression","expression":"(((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / 4) + 1) ==
4)"},{"type":"bound","dimension":"__time","lower":"11","lowerStrict":false,"upper":"12","upperStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"M","timeZone":"US/Pacific","locale":"en-US"}}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / CAST(4, 'DOUBLE')) + CAST(1,
'DOUBLE'))","outputType":"DOUBLE"},{"type":"expression","name":"vc0","expression":"timestamp_extract(\"__time\",'MONTH','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc1","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy
-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
5,
2)","outputType":"STRING"}],"columns":["vc","vc0","vc1"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: double), vc0 (type: int), vc1 (type: string)
outputColumnNames: _col0, _col1, _col2
ListSink
-PREHOOK: query: SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1, EXTRACT(MONTH
FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 6, 2) as
month_str FROM druid_table
+PREHOOK: query: SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1, EXTRACT(MONTH
FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 6, 2) as
month_str FROM druid_table_alltypesorc
WHERE EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 AND EXTRACT(MONTH FROM
`__time`) BETWEEN 11 AND 12 LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1, EXTRACT(MONTH
FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 6, 2) as
month_str FROM druid_table
+POSTHOOK: query: SELECT EXTRACT(MONTH FROM `__time`) / 4 + 1, EXTRACT(MONTH
FROM `__time`), SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 6, 2) as
month_str FROM druid_table_alltypesorc
WHERE EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 AND EXTRACT(MONTH FROM
`__time`) BETWEEN 11 AND 12 LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
4.0 12 12
-PREHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH
FROM `__time`) / 4 + 1 as q_number FROM druid_table WHERE EXTRACT(QUARTER from
`__time`) >= 4
+PREHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH
FROM `__time`) / 4 + 1 as q_number FROM druid_table_alltypesorc WHERE
EXTRACT(QUARTER from `__time`) >= 4
AND EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 LIMIT 1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH
FROM `__time`) / 4 + 1 as q_number FROM druid_table WHERE EXTRACT(QUARTER from
`__time`) >= 4
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH
FROM `__time`) / 4 + 1 as q_number FROM druid_table_alltypesorc WHERE
EXTRACT(QUARTER from `__time`) >= 4
AND EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
@@ -617,32 +566,32 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc,vc0
druid.fieldTypes int,double
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"and","fields":[{"type":"expression","expression":"(timestamp_extract(\"__time\",'QUARTER','US/Pacific')
>=
4)"},{"type":"expression","expression":"(((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / 4) + 1) ==
4)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'QUARTER','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / CAST(4, 'DOUBLE')) + CAST(1,
'DOUBLE'))","outputType":"DOUBLE"}],"columns":["vc","vc0"],"resultFormat":"compactedList","limit":1}
+ 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":"and","fields":[{"type":"expression","expression":"(timestamp_extract(\"__time\",'QUARTER','US/Pacific')
>=
4)"},{"type":"expression","expression":"(((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / 4) + 1) ==
4)"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'QUARTER','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"((CAST(timestamp_extract(\"__time\",'MONTH','US/Pacific'),
'DOUBLE') / CAST(4, 'DOUBLE')) + CAST(1,
'DOUBLE'))","outputType":"DOUBLE"}],"columns":["vc","vc0"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int), vc0 (type: double)
outputColumnNames: _col0, _col1
ListSink
-PREHOOK: query: SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH FROM
`__time`) / 4 + 1 as q_number FROM druid_table WHERE EXTRACT(QUARTER from
`__time`) >= 4
+PREHOOK: query: SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH FROM
`__time`) / 4 + 1 as q_number FROM druid_table_alltypesorc WHERE
EXTRACT(QUARTER from `__time`) >= 4
AND EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH FROM
`__time`) / 4 + 1 as q_number FROM druid_table WHERE EXTRACT(QUARTER from
`__time`) >= 4
+POSTHOOK: query: SELECT EXTRACT(QUARTER from `__time`), EXTRACT(MONTH FROM
`__time`) / 4 + 1 as q_number FROM druid_table_alltypesorc WHERE
EXTRACT(QUARTER from `__time`) >= 4
AND EXTRACT(MONTH FROM `__time`) / 4 + 1 = 4 LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
4 4.0
-PREHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) AS year_str FROM
druid_table WHERE EXTRACT(YEAR from `__time`) >= 1969
+PREHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) AS year_str FROM
druid_table_alltypesorc WHERE EXTRACT(YEAR from `__time`) >= 1969
AND CAST(EXTRACT(YEAR from `__time`) as STRING) = '1969' LIMIT 1
PREHOOK: type: QUERY
-POSTHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) AS year_str FROM
druid_table WHERE EXTRACT(YEAR from `__time`) >= 1969
+POSTHOOK: query: EXPLAIN SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) AS year_str FROM
druid_table_alltypesorc WHERE EXTRACT(YEAR from `__time`) >= 1969
AND CAST(EXTRACT(YEAR from `__time`) as STRING) = '1969' LIMIT 1
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
@@ -654,31 +603,31 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc,vc0
druid.fieldTypes int,string
- druid.query.json
{"queryType":"scan","dataSource":"default.druid_table","intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"],"filter":{"type":"and","fields":[{"type":"bound","dimension":"__time","lower":"1969","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"yyyy","timeZone":"US/Pacific","locale":"en-US"}},{"type":"expression","expression":"(CAST(timestamp_extract(\"__time\",'YEAR','US/Pacific'),
'STRING') ==
'1969')"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'YEAR','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
0,
4)","outputType":"STRING"}],"columns":["vc","vc0"],"resultFormat":"compactedList","limit":1}
+ 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":"and","fields":[{"type":"bound","dimension":"__time","lower":"1969","lowerStrict":false,"ordering":"numeric","extractionFn":{"type":"timeFormat","format":"yyyy","timeZone":"US/Pacific","locale":"en-US"}},{"type":"expression","expression":"(CAST(timestamp_extract(\"__time\",'YEAR','US/Pacific'),
'STRING') ==
'1969')"}]},"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_extract(\"__time\",'YEAR','US/Pacific')","outputType":"LONG"},{"type":"expression","name":"vc0","expression":"substring(timestamp_format(timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC'),'yyyy-MM-dd','UTC'),
0,
4)","outputType":"STRING"}],"columns":["vc","vc0"],"resultFormat":"compactedList","limit":1}
druid.query.type scan
Select Operator
expressions: vc (type: int), vc0 (type: string)
outputColumnNames: _col0, _col1
ListSink
-PREHOOK: query: SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) as year_str FROM
druid_table WHERE EXTRACT(YEAR from `__time`) >= 1969
+PREHOOK: query: SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) as year_str FROM
druid_table_alltypesorc WHERE EXTRACT(YEAR from `__time`) >= 1969
AND CAST(EXTRACT(YEAR from `__time`) as STRING) = '1969' LIMIT 1
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) as year_str FROM
druid_table WHERE EXTRACT(YEAR from `__time`) >= 1969
+POSTHOOK: query: SELECT EXTRACT(YEAR from `__time`),
SUBSTRING(CAST(CAST(`__time` AS DATE) AS STRING), 1, 4) as year_str FROM
druid_table_alltypesorc WHERE EXTRACT(YEAR from `__time`) >= 1969
AND CAST(EXTRACT(YEAR from `__time`) as STRING) = '1969' LIMIT 1
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1969 1969
-PREHOOK: query: explain SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`,
SUM(cfloat) FROM druid_table GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY
`x_time` LIMIT 5
+PREHOOK: query: explain SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`,
SUM(cfloat) FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS TIMESTAMP)
ORDER BY `x_time` LIMIT 5
PREHOOK: type: QUERY
-POSTHOOK: query: explain SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`,
SUM(cfloat) FROM druid_table GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY
`x_time` LIMIT 5
+POSTHOOK: query: explain SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`,
SUM(cfloat) FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS TIMESTAMP)
ORDER BY `x_time` LIMIT 5
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
Stage-0 is a root stage
@@ -689,30 +638,30 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames extract,$f1
druid.fieldTypes timestamp,double
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"extraction","dimension":"__time","outputName":"extract","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd
HH:mm:ss","timeZone":"US/Pacific","locale":"en"}}],"limitSpec":{"type":"default","limit":5,"columns":[{"dimension":"extract","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"}],"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":"extraction","dimension":"__time","outputName":"extract","extractionFn":{"type":"timeFormat","format":"yyyy-MM-dd
HH:mm:ss","timeZone":"US/Pacific","locale":"en"}}],"limitSpec":{"type":"default","limit":5,"columns":[{"dimension":"extract","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: extract (type: timestamp), $f1 (type: double)
outputColumnNames: _col0, _col1
ListSink
-PREHOOK: query: SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`, SUM(cfloat)
FROM druid_table GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY `x_time` LIMIT 5
+PREHOOK: query: SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`, SUM(cfloat)
FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY
`x_time` LIMIT 5
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`, SUM(cfloat)
FROM druid_table GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY `x_time` LIMIT 5
+POSTHOOK: query: SELECT CAST(`__time` AS TIMESTAMP) AS `x_time`, SUM(cfloat)
FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS TIMESTAMP) ORDER BY
`x_time` LIMIT 5
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1969-12-31 15:59:00 -4532.570196151733
1969-12-31 16:00:00 -35057.677050709724
-PREHOOK: query: explain SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat)
FROM druid_table GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date` LIMIT 5
+PREHOOK: query: explain SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat)
FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date`
LIMIT 5
PREHOOK: type: QUERY
-POSTHOOK: query: explain SELECT CAST(`__time` AS DATE) AS `x_date`,
SUM(cfloat) FROM druid_table GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date`
LIMIT 5
+POSTHOOK: query: explain SELECT CAST(`__time` AS DATE) AS `x_date`,
SUM(cfloat) FROM druid_table_alltypesorc GROUP BY CAST(`__time` AS DATE) ORDER
BY `x_date` LIMIT 5
POSTHOOK: type: QUERY
STAGE DEPENDENCIES:
Stage-0 is a root stage
@@ -723,33 +672,33 @@ STAGE PLANS:
limit: -1
Processor Tree:
TableScan
- alias: druid_table
+ alias: druid_table_alltypesorc
properties:
druid.fieldNames vc,$f1
druid.fieldTypes date,double
- druid.query.json
{"queryType":"groupBy","dataSource":"default.druid_table","granularity":"all","dimensions":[{"type":"default","dimension":"vc","outputName":"vc","outputType":"LONG"}],"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC')","outputType":"LONG"}],"limitSpec":{"type":"default","limit":5,"columns":[{"dimension":"vc","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"}],"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":"vc","outputName":"vc","outputType":"LONG"}],"virtualColumns":[{"type":"expression","name":"vc","expression":"timestamp_floor(timestamp_parse(timestamp_format(\"__time\",'yyyy-MM-dd\\u0027T\\u0027HH:mm:ss.SSS\\u0027Z\\u0027','US/Pacific'),'','UTC'),'P1D','','UTC')","outputType":"LONG"}],"limitSpec":{"type":"default","limit":5,"columns":[{"dimension":"vc","direction":"ascending","dimensionOrder":"lexicographic"}]},"aggregations":[{"type":"doubleSum","name":"$f1","fieldName":"cfloat"}],"intervals":["1900-01-01T00:00:00.000Z/3000-01-01T00:00:00.000Z"]}
druid.query.type groupBy
Select Operator
expressions: vc (type: date), $f1 (type: double)
outputColumnNames: _col0, _col1
ListSink
-PREHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat) FROM
druid_table GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date` LIMIT 5
+PREHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat) FROM
druid_table_alltypesorc GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date` LIMIT
5
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat) FROM
druid_table GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date` LIMIT 5
+POSTHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date`, SUM(cfloat) FROM
druid_table_alltypesorc GROUP BY CAST(`__time` AS DATE) ORDER BY `x_date` LIMIT
5
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1969-12-31 -39590.24724686146
-PREHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date` FROM druid_table
ORDER BY `x_date` LIMIT 5
+PREHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date` FROM
druid_table_alltypesorc ORDER BY `x_date` LIMIT 5
PREHOOK: type: QUERY
-PREHOOK: Input: default@druid_table
+PREHOOK: Input: default@druid_table_alltypesorc
PREHOOK: Output: hdfs://### HDFS PATH ###
-POSTHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date` FROM druid_table
ORDER BY `x_date` LIMIT 5
+POSTHOOK: query: SELECT CAST(`__time` AS DATE) AS `x_date` FROM
druid_table_alltypesorc ORDER BY `x_date` LIMIT 5
POSTHOOK: type: QUERY
-POSTHOOK: Input: default@druid_table
+POSTHOOK: Input: default@druid_table_alltypesorc
POSTHOOK: Output: hdfs://### HDFS PATH ###
1969-12-31
1969-12-31
@@ -859,11 +808,3 @@ POSTHOOK: query: DROP TABLE
test_extract_from_string_base_table
POSTHOOK: type: DROPTABLE
POSTHOOK: Input: default@test_extract_from_string_base_table
POSTHOOK: Output: default@test_extract_from_string_base_table
-PREHOOK: query: DROP TABLE druid_table
-PREHOOK: type: DROPTABLE
-PREHOOK: Input: default@druid_table
-PREHOOK: Output: default@druid_table
-POSTHOOK: query: DROP TABLE druid_table
-POSTHOOK: type: DROPTABLE
-POSTHOOK: Input: default@druid_table
-POSTHOOK: Output: default@druid_table
