f82ecffec751c3a7c870eec8fde91b9377383671
[hive.git] / ql / src / test / results / clientpositive / druid / druidmini_dynamic_partition.q.out
1 PREHOOK: query: CREATE TABLE druid_partitioned_table_0
2         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
3         TBLPROPERTIES (
4         "druid.segment.granularity" = "HOUR",
5         "druid.query.granularity" = "MINUTE",
6         "druid.segment.targetShardsPerGranularity" = "0"
7         )
8         AS
9         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
10           cstring1,
11           cstring2,
12           cdouble,
13           cfloat,
14           ctinyint,
15           csmallint,
16           cint,
17           cbigint,
18           cboolean1,
19           cboolean2
20           FROM alltypesorc where ctimestamp1 IS NOT NULL
21 PREHOOK: type: CREATETABLE_AS_SELECT
22 PREHOOK: Input: default@alltypesorc
23 PREHOOK: Output: database:default
24 PREHOOK: Output: default@druid_partitioned_table_0
25 POSTHOOK: query: CREATE TABLE druid_partitioned_table_0
26         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
27         TBLPROPERTIES (
28         "druid.segment.granularity" = "HOUR",
29         "druid.query.granularity" = "MINUTE",
30         "druid.segment.targetShardsPerGranularity" = "0"
31         )
32         AS
33         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
34           cstring1,
35           cstring2,
36           cdouble,
37           cfloat,
38           ctinyint,
39           csmallint,
40           cint,
41           cbigint,
42           cboolean1,
43           cboolean2
44           FROM alltypesorc where ctimestamp1 IS NOT NULL
45 POSTHOOK: type: CREATETABLE_AS_SELECT
46 POSTHOOK: Input: default@alltypesorc
47 POSTHOOK: Output: database:default
48 POSTHOOK: Output: default@druid_partitioned_table_0
49 POSTHOOK: Lineage: druid_partitioned_table_0.__time EXPRESSION [(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp, comment:null), ]
50 POSTHOOK: Lineage: druid_partitioned_table_0.cbigint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null), ]
51 POSTHOOK: Lineage: druid_partitioned_table_0.cboolean1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean, comment:null), ]
52 POSTHOOK: Lineage: druid_partitioned_table_0.cboolean2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean, comment:null), ]
53 POSTHOOK: Lineage: druid_partitioned_table_0.cdouble SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null), ]
54 POSTHOOK: Lineage: druid_partitioned_table_0.cfloat SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ]
55 POSTHOOK: Lineage: druid_partitioned_table_0.cint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ]
56 POSTHOOK: Lineage: druid_partitioned_table_0.csmallint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint, comment:null), ]
57 POSTHOOK: Lineage: druid_partitioned_table_0.cstring1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ]
58 POSTHOOK: Lineage: druid_partitioned_table_0.cstring2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string, comment:null), ]
59 POSTHOOK: Lineage: druid_partitioned_table_0.ctinyint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint, comment:null), ]
60 PREHOOK: query: EXPLAIN CREATE TABLE druid_partitioned_table
61         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
62         TBLPROPERTIES (
63         "druid.segment.granularity" = "HOUR",
64         "druid.query.granularity" = "MINUTE",
65         "druid.segment.targetShardsPerGranularity" = "6"
66         )
67         AS
68         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
69           cstring1,
70           cstring2,
71           cdouble,
72           cfloat,
73           ctinyint,
74           csmallint,
75           cint,
76           cbigint,
77           cboolean1,
78           cboolean2
79           FROM alltypesorc where ctimestamp1 IS NOT NULL
80 PREHOOK: type: CREATETABLE_AS_SELECT
81 POSTHOOK: query: EXPLAIN CREATE TABLE druid_partitioned_table
82         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
83         TBLPROPERTIES (
84         "druid.segment.granularity" = "HOUR",
85         "druid.query.granularity" = "MINUTE",
86         "druid.segment.targetShardsPerGranularity" = "6"
87         )
88         AS
89         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
90           cstring1,
91           cstring2,
92           cdouble,
93           cfloat,
94           ctinyint,
95           csmallint,
96           cint,
97           cbigint,
98           cboolean1,
99           cboolean2
100           FROM alltypesorc where ctimestamp1 IS NOT NULL
101 POSTHOOK: type: CREATETABLE_AS_SELECT
102 STAGE DEPENDENCIES:
103   Stage-1 is a root stage
104   Stage-2 depends on stages: Stage-1
105   Stage-4 depends on stages: Stage-2, Stage-0
106   Stage-3 depends on stages: Stage-4
107   Stage-0 depends on stages: Stage-1
108
109 STAGE PLANS:
110   Stage: Stage-1
111     Tez
112 #### A masked pattern was here ####
113       Edges:
114         Reducer 2 <- Map 1 (SIMPLE_EDGE)
115 #### A masked pattern was here ####
116       Vertices:
117         Map 1 
118             Map Operator Tree:
119                 TableScan
120                   alias: alltypesorc
121                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
122                   Filter Operator
123                     predicate: ctimestamp1 is not null (type: boolean)
124                     Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
125                     Select Operator
126                       expressions: CAST( ctimestamp1 AS timestamp with local time zone) (type: timestamp with local time zone), cstring1 (type: string), cstring2 (type: string), cdouble (type: double), cfloat (type: float), ctinyint (type: tinyint), csmallint (type: smallint), cint (type: int), cbigint (type: bigint), cboolean1 (type: boolean), cboolean2 (type: boolean)
127                       outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10
128                       Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
129                       Select Operator
130                         expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean), floor_hour(CAST( GenericUDFEpochMilli(_col0) AS TIMESTAMP)) (type: timestamp), (floor((1.0 / rand())) % 6) (type: bigint)
131                         outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
132                         Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
133                         Reduce Output Operator
134                           key expressions: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
135                           sort order: ++
136                           Map-reduce partition columns: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
137                           Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
138                           value expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean)
139         Reducer 2 
140             Reduce Operator Tree:
141               Select Operator
142                 expressions: VALUE._col0 (type: timestamp with local time zone), VALUE._col1 (type: string), VALUE._col2 (type: string), VALUE._col3 (type: double), VALUE._col4 (type: float), VALUE._col5 (type: tinyint), VALUE._col6 (type: smallint), VALUE._col7 (type: int), VALUE._col8 (type: bigint), VALUE._col9 (type: boolean), VALUE._col10 (type: boolean), KEY.__time_granularity (type: timestamp), KEY.__druid_extra_partition_key (type: bigint)
143                 outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
144                 Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
145                 File Output Operator
146                   compressed: false
147                   Dp Sort State: PARTITION_SORTED
148                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
149                   table:
150                       input format: org.apache.hadoop.hive.druid.io.DruidQueryBasedInputFormat
151                       output format: org.apache.hadoop.hive.druid.io.DruidOutputFormat
152                       serde: org.apache.hadoop.hive.druid.serde.DruidSerDe
153                       name: default.druid_partitioned_table
154
155   Stage: Stage-2
156     Dependency Collection
157
158   Stage: Stage-4
159       Create Table Operator:
160         Create Table
161           columns: __time timestamp with local time zone, cstring1 string, cstring2 string, cdouble double, cfloat float, ctinyint tinyint, csmallint smallint, cint int, cbigint bigint, cboolean1 boolean, cboolean2 boolean
162           storage handler: org.apache.hadoop.hive.druid.DruidStorageHandler
163           name: default.druid_partitioned_table
164           table properties:
165             druid.query.granularity MINUTE
166             druid.segment.granularity HOUR
167             druid.segment.targetShardsPerGranularity 6
168
169   Stage: Stage-3
170     Stats Work
171       Basic Stats Work:
172
173   Stage: Stage-0
174     Move Operator
175       files:
176           hdfs directory: true
177           destination: hdfs://### HDFS PATH ###
178
179 PREHOOK: query: CREATE TABLE druid_partitioned_table
180 STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
181 TBLPROPERTIES (
182 "druid.segment.granularity" = "HOUR",
183 "druid.query.granularity" = "MINUTE",
184 "druid.segment.targetShardsPerGranularity" = "6"
185 )
186 AS
187 SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
188   cstring1,
189   cstring2,
190   cdouble,
191   cfloat,
192   ctinyint,
193   csmallint,
194   cint,
195   cbigint,
196   cboolean1,
197   cboolean2
198   FROM alltypesorc where ctimestamp1 IS NOT NULL
199 PREHOOK: type: CREATETABLE_AS_SELECT
200 PREHOOK: Input: default@alltypesorc
201 PREHOOK: Output: database:default
202 PREHOOK: Output: default@druid_partitioned_table
203 POSTHOOK: query: CREATE TABLE druid_partitioned_table
204 STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
205 TBLPROPERTIES (
206 "druid.segment.granularity" = "HOUR",
207 "druid.query.granularity" = "MINUTE",
208 "druid.segment.targetShardsPerGranularity" = "6"
209 )
210 AS
211 SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
212   cstring1,
213   cstring2,
214   cdouble,
215   cfloat,
216   ctinyint,
217   csmallint,
218   cint,
219   cbigint,
220   cboolean1,
221   cboolean2
222   FROM alltypesorc where ctimestamp1 IS NOT NULL
223 POSTHOOK: type: CREATETABLE_AS_SELECT
224 POSTHOOK: Input: default@alltypesorc
225 POSTHOOK: Output: database:default
226 POSTHOOK: Output: default@druid_partitioned_table
227 POSTHOOK: Lineage: druid_partitioned_table.__time EXPRESSION [(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp, comment:null), ]
228 POSTHOOK: Lineage: druid_partitioned_table.cbigint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null), ]
229 POSTHOOK: Lineage: druid_partitioned_table.cboolean1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean, comment:null), ]
230 POSTHOOK: Lineage: druid_partitioned_table.cboolean2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean, comment:null), ]
231 POSTHOOK: Lineage: druid_partitioned_table.cdouble SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null), ]
232 POSTHOOK: Lineage: druid_partitioned_table.cfloat SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ]
233 POSTHOOK: Lineage: druid_partitioned_table.cint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ]
234 POSTHOOK: Lineage: druid_partitioned_table.csmallint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint, comment:null), ]
235 POSTHOOK: Lineage: druid_partitioned_table.cstring1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ]
236 POSTHOOK: Lineage: druid_partitioned_table.cstring2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string, comment:null), ]
237 POSTHOOK: Lineage: druid_partitioned_table.ctinyint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint, comment:null), ]
238 PREHOOK: query: SELECT sum(cfloat)  FROM druid_partitioned_table
239 PREHOOK: type: QUERY
240 PREHOOK: Input: default@druid_partitioned_table
241 PREHOOK: Output: hdfs://### HDFS PATH ###
242 POSTHOOK: query: SELECT sum(cfloat)  FROM druid_partitioned_table
243 POSTHOOK: type: QUERY
244 POSTHOOK: Input: default@druid_partitioned_table
245 POSTHOOK: Output: hdfs://### HDFS PATH ###
246 -39590.246
247 PREHOOK: query: SELECT floor_hour(cast(`ctimestamp1` as timestamp with local time zone)) as `__time`,
248           cstring1,
249           cstring2,
250           cdouble,
251           cfloat,
252           ctinyint,
253           csmallint,
254           cint,
255           cbigint,
256           cboolean1,
257           cboolean2
258           FROM alltypesorc where ctimestamp1 IS NOT NULL order by `__time`, cstring2 DESC NULLS LAST, cstring1 DESC NULLS LAST LIMIT 10
259 PREHOOK: type: QUERY
260 PREHOOK: Input: default@alltypesorc
261 PREHOOK: Output: hdfs://### HDFS PATH ###
262 POSTHOOK: query: SELECT floor_hour(cast(`ctimestamp1` as timestamp with local time zone)) as `__time`,
263           cstring1,
264           cstring2,
265           cdouble,
266           cfloat,
267           ctinyint,
268           csmallint,
269           cint,
270           cbigint,
271           cboolean1,
272           cboolean2
273           FROM alltypesorc where ctimestamp1 IS NOT NULL order by `__time`, cstring2 DESC NULLS LAST, cstring1 DESC NULLS LAST LIMIT 10
274 POSTHOOK: type: QUERY
275 POSTHOOK: Input: default@alltypesorc
276 POSTHOOK: Output: hdfs://### HDFS PATH ###
277 1969-12-31 15:00:00.0 US/Pacific        NULL    yx36UAT823Cm    -200.0  52.0    52      -200    NULL    2029007949      NULL    true
278 1969-12-31 15:00:00.0 US/Pacific        NULL    yvcx4HYTT8tvAm6CNbXHaH  -7196.0 40.0    40      -7196   NULL    437984126       NULL    false
279 1969-12-31 15:00:00.0 US/Pacific        NULL    ysho54gMb       15601.0 -22.0   -22     15601   NULL    1553802956      NULL    false
280 1969-12-31 15:00:00.0 US/Pacific        NULL    yqXw7J7 15601.0 44.0    44      15601   NULL    1265051089      NULL    true
281 1969-12-31 15:00:00.0 US/Pacific        NULL    yfpFFQ0 15601.0 11.0    11      15601   NULL    11070716        NULL    false
282 1969-12-31 15:00:00.0 US/Pacific        NULL    ySl6tu66m72erf1 -200.0  -50.0   -50     -200    NULL    824529348       NULL    false
283 1969-12-31 15:00:00.0 US/Pacific        NULL    yPUM0wC54vq     15601.0 -8.0    -8      15601   NULL    1821279179      NULL    true
284 1969-12-31 15:00:00.0 US/Pacific        NULL    yOgijYXi753GboFW7L1x65l -7196.0 -34.0   -34     -7196   NULL    -1022931985     NULL    false
285 1969-12-31 15:00:00.0 US/Pacific        NULL    yO7xKhbtrsBU147xuT0CF7Q 15601.0 47.0    47      15601   NULL    661404907       NULL    true
286 1969-12-31 15:00:00.0 US/Pacific        NULL    yLB85lr145622oTRo       -200.0  -41.0   -41     -200    NULL    -260138227      NULL    true
287 PREHOOK: query: EXPLAIN INSERT INTO TABLE druid_partitioned_table
288 SELECT cast (`ctimestamp2` as timestamp with local time zone) as `__time`,
289   cstring1,
290   cstring2,
291   cdouble,
292   cfloat,
293   ctinyint,
294   csmallint,
295   cint,
296   cbigint,
297   cboolean1,
298   cboolean2
299   FROM alltypesorc where ctimestamp2 IS NOT NULL
300 PREHOOK: type: QUERY
301 POSTHOOK: query: EXPLAIN INSERT INTO TABLE druid_partitioned_table
302 SELECT cast (`ctimestamp2` as timestamp with local time zone) as `__time`,
303   cstring1,
304   cstring2,
305   cdouble,
306   cfloat,
307   ctinyint,
308   csmallint,
309   cint,
310   cbigint,
311   cboolean1,
312   cboolean2
313   FROM alltypesorc where ctimestamp2 IS NOT NULL
314 POSTHOOK: type: QUERY
315 STAGE DEPENDENCIES:
316   Stage-0 is a root stage
317   Stage-2
318   Stage-1 is a root stage
319   Stage-3 is a root stage
320
321 STAGE PLANS:
322   Stage: Stage-0
323       Alter Table Operator:
324         Alter Table
325           type: drop props
326           old name: default.druid_partitioned_table
327           properties:
328             COLUMN_STATS_ACCURATE 
329
330   Stage: Stage-2
331       Insert operator:
332         Insert
333
334   Stage: Stage-1
335       Pre Insert operator:
336         Pre-Insert task
337
338   Stage: Stage-3
339     Tez
340 #### A masked pattern was here ####
341       Edges:
342         Reducer 2 <- Map 1 (SIMPLE_EDGE)
343 #### A masked pattern was here ####
344       Vertices:
345         Map 1 
346             Map Operator Tree:
347                 TableScan
348                   alias: alltypesorc
349                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
350                   Filter Operator
351                     predicate: ctimestamp2 is not null (type: boolean)
352                     Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
353                     Select Operator
354                       expressions: CAST( ctimestamp2 AS timestamp with local time zone) (type: timestamp with local time zone), cstring1 (type: string), cstring2 (type: string), cdouble (type: double), cfloat (type: float), ctinyint (type: tinyint), csmallint (type: smallint), cint (type: int), cbigint (type: bigint), cboolean1 (type: boolean), cboolean2 (type: boolean)
355                       outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10
356                       Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
357                       Select Operator
358                         expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean), floor_hour(CAST( GenericUDFEpochMilli(_col0) AS TIMESTAMP)) (type: timestamp), (floor((1.0 / rand())) % 6) (type: bigint)
359                         outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
360                         Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
361                         Reduce Output Operator
362                           key expressions: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
363                           sort order: ++
364                           Map-reduce partition columns: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
365                           Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
366                           value expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean)
367         Reducer 2 
368             Reduce Operator Tree:
369               Select Operator
370                 expressions: VALUE._col0 (type: timestamp with local time zone), VALUE._col1 (type: string), VALUE._col2 (type: string), VALUE._col3 (type: double), VALUE._col4 (type: float), VALUE._col5 (type: tinyint), VALUE._col6 (type: smallint), VALUE._col7 (type: int), VALUE._col8 (type: bigint), VALUE._col9 (type: boolean), VALUE._col10 (type: boolean), KEY.__time_granularity (type: timestamp), KEY.__druid_extra_partition_key (type: bigint)
371                 outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
372                 Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
373                 File Output Operator
374                   compressed: false
375                   Dp Sort State: PARTITION_SORTED
376                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
377                   table:
378                       input format: org.apache.hadoop.hive.druid.io.DruidQueryBasedInputFormat
379                       output format: org.apache.hadoop.hive.druid.io.DruidOutputFormat
380                       serde: org.apache.hadoop.hive.druid.serde.DruidSerDe
381                       name: default.druid_partitioned_table
382
383 PREHOOK: query: INSERT INTO TABLE druid_partitioned_table
384 SELECT cast (`ctimestamp2` as timestamp with local time zone) as `__time`,
385   cstring1,
386   cstring2,
387   cdouble,
388   cfloat,
389   ctinyint,
390   csmallint,
391   cint,
392   cbigint,
393   cboolean1,
394   cboolean2
395   FROM alltypesorc where ctimestamp2 IS NOT NULL
396 PREHOOK: type: QUERY
397 PREHOOK: Input: default@alltypesorc
398 PREHOOK: Output: default@druid_partitioned_table
399 POSTHOOK: query: INSERT INTO TABLE druid_partitioned_table
400 SELECT cast (`ctimestamp2` as timestamp with local time zone) as `__time`,
401   cstring1,
402   cstring2,
403   cdouble,
404   cfloat,
405   ctinyint,
406   csmallint,
407   cint,
408   cbigint,
409   cboolean1,
410   cboolean2
411   FROM alltypesorc where ctimestamp2 IS NOT NULL
412 POSTHOOK: type: QUERY
413 POSTHOOK: Input: default@alltypesorc
414 POSTHOOK: Output: default@druid_partitioned_table
415 PREHOOK: query: SELECT  sum(cfloat)  FROM druid_partitioned_table
416 PREHOOK: type: QUERY
417 PREHOOK: Input: default@druid_partitioned_table
418 PREHOOK: Output: hdfs://### HDFS PATH ###
419 POSTHOOK: query: SELECT  sum(cfloat)  FROM druid_partitioned_table
420 POSTHOOK: type: QUERY
421 POSTHOOK: Input: default@druid_partitioned_table
422 POSTHOOK: Output: hdfs://### HDFS PATH ###
423 -46301.883
424 PREHOOK: query: EXPLAIN INSERT OVERWRITE TABLE druid_partitioned_table
425   SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
426     cstring1,
427     cstring2,
428     cdouble,
429     cfloat,
430     ctinyint,
431     csmallint,
432     cint,
433     cbigint,
434     cboolean1,
435     cboolean2
436     FROM alltypesorc where ctimestamp1 IS NOT NULL
437 PREHOOK: type: QUERY
438 POSTHOOK: query: EXPLAIN INSERT OVERWRITE TABLE druid_partitioned_table
439   SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
440     cstring1,
441     cstring2,
442     cdouble,
443     cfloat,
444     ctinyint,
445     csmallint,
446     cint,
447     cbigint,
448     cboolean1,
449     cboolean2
450     FROM alltypesorc where ctimestamp1 IS NOT NULL
451 POSTHOOK: type: QUERY
452 STAGE DEPENDENCIES:
453   Stage-0 is a root stage
454   Stage-2
455   Stage-1 is a root stage
456   Stage-3 is a root stage
457
458 STAGE PLANS:
459   Stage: Stage-0
460       Alter Table Operator:
461         Alter Table
462           type: drop props
463           old name: default.druid_partitioned_table
464           properties:
465             COLUMN_STATS_ACCURATE 
466
467   Stage: Stage-2
468       Insert operator:
469         Insert
470
471   Stage: Stage-1
472       Pre Insert operator:
473         Pre-Insert task
474
475   Stage: Stage-3
476     Tez
477 #### A masked pattern was here ####
478       Edges:
479         Reducer 2 <- Map 1 (SIMPLE_EDGE)
480 #### A masked pattern was here ####
481       Vertices:
482         Map 1 
483             Map Operator Tree:
484                 TableScan
485                   alias: alltypesorc
486                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
487                   Filter Operator
488                     predicate: ctimestamp1 is not null (type: boolean)
489                     Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
490                     Select Operator
491                       expressions: CAST( ctimestamp1 AS timestamp with local time zone) (type: timestamp with local time zone), cstring1 (type: string), cstring2 (type: string), cdouble (type: double), cfloat (type: float), ctinyint (type: tinyint), csmallint (type: smallint), cint (type: int), cbigint (type: bigint), cboolean1 (type: boolean), cboolean2 (type: boolean)
492                       outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10
493                       Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
494                       Select Operator
495                         expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean), floor_hour(CAST( GenericUDFEpochMilli(_col0) AS TIMESTAMP)) (type: timestamp), (floor((1.0 / rand())) % 6) (type: bigint)
496                         outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
497                         Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
498                         Reduce Output Operator
499                           key expressions: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
500                           sort order: ++
501                           Map-reduce partition columns: __time_granularity (type: timestamp), __druid_extra_partition_key (type: bigint)
502                           Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
503                           value expressions: _col0 (type: timestamp with local time zone), _col1 (type: string), _col2 (type: string), _col3 (type: double), _col4 (type: float), _col5 (type: tinyint), _col6 (type: smallint), _col7 (type: int), _col8 (type: bigint), _col9 (type: boolean), _col10 (type: boolean)
504         Reducer 2 
505             Reduce Operator Tree:
506               Select Operator
507                 expressions: VALUE._col0 (type: timestamp with local time zone), VALUE._col1 (type: string), VALUE._col2 (type: string), VALUE._col3 (type: double), VALUE._col4 (type: float), VALUE._col5 (type: tinyint), VALUE._col6 (type: smallint), VALUE._col7 (type: int), VALUE._col8 (type: bigint), VALUE._col9 (type: boolean), VALUE._col10 (type: boolean), KEY.__time_granularity (type: timestamp), KEY.__druid_extra_partition_key (type: bigint)
508                 outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5, _col6, _col7, _col8, _col9, _col10, __time_granularity, __druid_extra_partition_key
509                 Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
510                 File Output Operator
511                   compressed: false
512                   Dp Sort State: PARTITION_SORTED
513                   Statistics: Num rows: 12288 Data size: 2601650 Basic stats: COMPLETE Column stats: COMPLETE
514                   table:
515                       input format: org.apache.hadoop.hive.druid.io.DruidQueryBasedInputFormat
516                       output format: org.apache.hadoop.hive.druid.io.DruidOutputFormat
517                       serde: org.apache.hadoop.hive.druid.serde.DruidSerDe
518                       name: default.druid_partitioned_table
519
520 PREHOOK: query: INSERT OVERWRITE TABLE druid_partitioned_table
521   SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
522     cstring1,
523     cstring2,
524     cdouble,
525     cfloat,
526     ctinyint,
527     csmallint,
528     cint,
529     cbigint,
530     cboolean1,
531     cboolean2
532     FROM alltypesorc where ctimestamp1 IS NOT NULL
533 PREHOOK: type: QUERY
534 PREHOOK: Input: default@alltypesorc
535 PREHOOK: Output: default@druid_partitioned_table
536 POSTHOOK: query: INSERT OVERWRITE TABLE druid_partitioned_table
537   SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
538     cstring1,
539     cstring2,
540     cdouble,
541     cfloat,
542     ctinyint,
543     csmallint,
544     cint,
545     cbigint,
546     cboolean1,
547     cboolean2
548     FROM alltypesorc where ctimestamp1 IS NOT NULL
549 POSTHOOK: type: QUERY
550 POSTHOOK: Input: default@alltypesorc
551 POSTHOOK: Output: default@druid_partitioned_table
552 PREHOOK: query: SELECT  sum(cfloat)  FROM druid_partitioned_table
553 PREHOOK: type: QUERY
554 PREHOOK: Input: default@druid_partitioned_table
555 PREHOOK: Output: hdfs://### HDFS PATH ###
556 POSTHOOK: query: SELECT  sum(cfloat)  FROM druid_partitioned_table
557 POSTHOOK: type: QUERY
558 POSTHOOK: Input: default@druid_partitioned_table
559 POSTHOOK: Output: hdfs://### HDFS PATH ###
560 -39590.246
561 PREHOOK: query: CREATE TABLE druid_max_size_partition
562         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
563         TBLPROPERTIES (
564         "druid.segment.granularity" = "HOUR",
565         "druid.query.granularity" = "MINUTE"
566         )
567         AS
568         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
569           cstring1,
570           cstring2,
571           cdouble,
572           cfloat,
573           ctinyint,
574           csmallint,
575           cint,
576           cbigint,
577           cboolean1,
578           cboolean2
579           FROM alltypesorc where ctimestamp1 IS NOT NULL
580 PREHOOK: type: CREATETABLE_AS_SELECT
581 PREHOOK: Input: default@alltypesorc
582 PREHOOK: Output: database:default
583 PREHOOK: Output: default@druid_max_size_partition
584 POSTHOOK: query: CREATE TABLE druid_max_size_partition
585         STORED BY 'org.apache.hadoop.hive.druid.DruidStorageHandler'
586         TBLPROPERTIES (
587         "druid.segment.granularity" = "HOUR",
588         "druid.query.granularity" = "MINUTE"
589         )
590         AS
591         SELECT cast (`ctimestamp1` as timestamp with local time zone) as `__time`,
592           cstring1,
593           cstring2,
594           cdouble,
595           cfloat,
596           ctinyint,
597           csmallint,
598           cint,
599           cbigint,
600           cboolean1,
601           cboolean2
602           FROM alltypesorc where ctimestamp1 IS NOT NULL
603 POSTHOOK: type: CREATETABLE_AS_SELECT
604 POSTHOOK: Input: default@alltypesorc
605 POSTHOOK: Output: database:default
606 POSTHOOK: Output: default@druid_max_size_partition
607 POSTHOOK: Lineage: druid_max_size_partition.__time EXPRESSION [(alltypesorc)alltypesorc.FieldSchema(name:ctimestamp1, type:timestamp, comment:null), ]
608 POSTHOOK: Lineage: druid_max_size_partition.cbigint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cbigint, type:bigint, comment:null), ]
609 POSTHOOK: Lineage: druid_max_size_partition.cboolean1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean1, type:boolean, comment:null), ]
610 POSTHOOK: Lineage: druid_max_size_partition.cboolean2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cboolean2, type:boolean, comment:null), ]
611 POSTHOOK: Lineage: druid_max_size_partition.cdouble SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cdouble, type:double, comment:null), ]
612 POSTHOOK: Lineage: druid_max_size_partition.cfloat SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cfloat, type:float, comment:null), ]
613 POSTHOOK: Lineage: druid_max_size_partition.cint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), ]
614 POSTHOOK: Lineage: druid_max_size_partition.csmallint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:csmallint, type:smallint, comment:null), ]
615 POSTHOOK: Lineage: druid_max_size_partition.cstring1 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ]
616 POSTHOOK: Lineage: druid_max_size_partition.cstring2 SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring2, type:string, comment:null), ]
617 POSTHOOK: Lineage: druid_max_size_partition.ctinyint SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:ctinyint, type:tinyint, comment:null), ]
618 PREHOOK: query: SELECT  sum(cfloat)  FROM druid_max_size_partition
619 PREHOOK: type: QUERY
620 PREHOOK: Input: default@druid_max_size_partition
621 PREHOOK: Output: hdfs://### HDFS PATH ###
622 POSTHOOK: query: SELECT  sum(cfloat)  FROM druid_max_size_partition
623 POSTHOOK: type: QUERY
624 POSTHOOK: Input: default@druid_max_size_partition
625 POSTHOOK: Output: hdfs://### HDFS PATH ###
626 -39590.246
627 PREHOOK: query: DROP TABLE druid_partitioned_table_0
628 PREHOOK: type: DROPTABLE
629 PREHOOK: Input: default@druid_partitioned_table_0
630 PREHOOK: Output: default@druid_partitioned_table_0
631 POSTHOOK: query: DROP TABLE druid_partitioned_table_0
632 POSTHOOK: type: DROPTABLE
633 POSTHOOK: Input: default@druid_partitioned_table_0
634 POSTHOOK: Output: default@druid_partitioned_table_0
635 PREHOOK: query: DROP TABLE druid_partitioned_table
636 PREHOOK: type: DROPTABLE
637 PREHOOK: Input: default@druid_partitioned_table
638 PREHOOK: Output: default@druid_partitioned_table
639 POSTHOOK: query: DROP TABLE druid_partitioned_table
640 POSTHOOK: type: DROPTABLE
641 POSTHOOK: Input: default@druid_partitioned_table
642 POSTHOOK: Output: default@druid_partitioned_table
643 PREHOOK: query: DROP TABLE druid_max_size_partition
644 PREHOOK: type: DROPTABLE
645 PREHOOK: Input: default@druid_max_size_partition
646 PREHOOK: Output: default@druid_max_size_partition
647 POSTHOOK: query: DROP TABLE druid_max_size_partition
648 POSTHOOK: type: DROPTABLE
649 POSTHOOK: Input: default@druid_max_size_partition
650 POSTHOOK: Output: default@druid_max_size_partition