CREATE TABLE AS SELECT

命令功能

CREATE TABLE As SELECT命令通过指定带有表属性的字段列表来创建Hudi Table。

命令格式

CREATE TABLE [ IF NOT EXISTS] [database_name.]table_name

USING hudi

[ COMMENT table_comment ]

[ LOCATION location_path ]

[ OPTIONS (options_list) ]

[ AS query_statement ]

参数描述

示例

• 创建分区表

  create table h2 using hudi
  options (type = 'cow', primaryKey = 'id')
  partitioned by (dt)
  as
  select 1 as id, 'a1' as name, 10 as price, 1000 as dt;

• 创建非分区表

  create table h3 using hudi
  as
  select 1 as id, 'a1' as name, 10 as price;
  
  从parquet表加载数据到hudi表
  # 创建parquet表
  create table parquet_mngd using parquet options(path=’hdfs:///tmp/parquet_dataset/*.parquet’);
  
  # CTAS创建hudi表
  create table hudi_tbl using hudi location 'hdfs:///tmp/hudi/hudi_tbl/' options (
  type = 'cow',
  primaryKey = 'id',
  preCombineField = 'ts'
  )
  partitioned by (datestr) as select * from parquet_mngd;

注意事项

为了更好的加载数据性能，CTAS使用bulk insert作为写入方式.

系统响应

Table创建成功，创建成功的消息将被记录在系统日志中。