testdata/workloads/functional-planner/queries/PlannerTest/ddl.test

create table t as select * from functional.alltypes
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
00:SCAN HDFS [functional.alltypes]
   partitions=24/24 files=24 size=478.45KB
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
00:SCAN HDFS [functional.alltypes]
   partitions=24/24 files=24 size=478.45KB
====
create table t as
select distinct a.int_col, a.string_col from functional.alltypes a
inner join functional.alltypessmall b on (a.id = b.id)
where a.year = 2009 and b.month = 2
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
03:AGGREGATE [FINALIZE]
|  group by: a.int_col, a.string_col
|
02:HASH JOIN [INNER JOIN]
|  hash predicates: a.id = b.id
|  runtime filters: RF000 <- b.id
|
|--01:SCAN HDFS [functional.alltypessmall b]
|     partitions=1/4 files=1 size=1.58KB
|
00:SCAN HDFS [functional.alltypes a]
   partitions=12/24 files=12 size=238.68KB
   runtime filters: RF000 -> a.id
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
06:AGGREGATE [FINALIZE]
|  group by: a.int_col, a.string_col
|
05:EXCHANGE [HASH(a.int_col,a.string_col)]
|
03:AGGREGATE [STREAMING]
|  group by: a.int_col, a.string_col
|
02:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: a.id = b.id
|  runtime filters: RF000 <- b.id
|
|--04:EXCHANGE [BROADCAST]
|  |
|  01:SCAN HDFS [functional.alltypessmall b]
|     partitions=1/4 files=1 size=1.58KB
|
00:SCAN HDFS [functional.alltypes a]
   partitions=12/24 files=12 size=238.68KB
   runtime filters: RF000 -> a.id
====
# CTAS with a view that has a limit clause (IMPALA-1411)
create table t as
select int_col from functional.hive_view
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
00:SCAN HDFS [functional.alltypes]
   partitions=24/24 files=24 size=478.45KB
   limit: 1
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
01:EXCHANGE [UNPARTITIONED]
|  limit: 1
|
00:SCAN HDFS [functional.alltypes]
   partitions=24/24 files=24 size=478.45KB
   limit: 1
====
# CTAS with multiple nested inline views that have a limit clause (IMPALA-1411)
create table t as
select * from
  (select * from
     (select int_col from functional.alltypestiny limit 1) v1 ) v2
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
   limit: 1
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
01:EXCHANGE [UNPARTITIONED]
|  limit: 1
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
   limit: 1
====

# CTAS with a select statement that has a limit and offset clause (IMPALA-1411)
create table t as
select * from functional.alltypestiny order by id limit 1 offset 5
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
01:TOP-N [LIMIT=1 OFFSET=5]
|  order by: id ASC
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
02:MERGING-EXCHANGE [UNPARTITIONED]
|  offset: 5
|  order by: id ASC
|  limit: 1
|
01:TOP-N [LIMIT=6]
|  order by: id ASC
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
====
# CTAS with an inline view that has a limit and offset clause (IMPALA-1411)
create table t as
select * from
  (select int_col from functional.alltypestiny order by id limit 2 offset 5) v
---- PLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
01:TOP-N [LIMIT=2 OFFSET=5]
|  order by: id ASC
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
---- DISTRIBUTEDPLAN
WRITE TO HDFS [default.t, OVERWRITE=false]
|  partitions=1
|
02:MERGING-EXCHANGE [UNPARTITIONED]
|  offset: 5
|  order by: id ASC
|  limit: 2
|
01:TOP-N [LIMIT=7]
|  order by: id ASC
|
00:SCAN HDFS [functional.alltypestiny]
   partitions=4/4 files=4 size=460B
====