Kudu相关

2022-10-26 字数：543 字阅读时长：约 3 分钟阅读次

表操作

表操作

新增表字段

alter TABLE ${table_name} add columns(${colume});

excample: alter TABLE kudu_test.bms_order add columns(to_goodstype TINYINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '货物类型');

更改表的名称

语法

ALTER TABLE重命名现有表的基本语法如下 -

ALTER TABLE [old_db_name.]old_table_name RENAME TO [new_db_name.]new_table_name

例

下面是使用alter语句更改表名称的示例。这里我们将表客户的名称更改为用户。

[quickstart.cloudera:21000] > ALTER TABLE my_db.customers RENAME TO my_db.users;

删除表字段

语法

ALTER TABLE ${table_name} DROP ${column_name};

例

ALTER TABLE kudu_pro.bms_order DROP bms_cu_knot_type;

建立分区表

示例sql

 CREATE TABLE kudu_pro.ods_temp_data (    
   load_date INT NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '加载日期-精确到小时',
   load_date1 INT NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '加载日期-精确到日期', 
   deviceid STRING NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '设备号',   
   time INT NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '数据采集时间',   
   uid STRING NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '消息唯一标识符',      
   humi0 INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '探头0-湿度',       
   humi1 INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '探头1-湿度',      
   temp0 INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '探头0-温度',           
   temp1 INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '探头1-温度',             
   lbstime INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT 'lbs时间，通过此时间去查找对应的定位点',             
   type INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION COMMENT '消息类型',               
   is_send TINYINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION DEFAULT 0 COMMENT '是否已推送 ，默认不推送：0 已推送：1',
   PRIMARY KEY (load_date, load_date1, deviceid, time, uid)                             
 )                                                                                                                                      
 PARTITION BY RANGE (load_date1) 
 (load_date1 = '20221026')                     
  COMMENT '温度基础数据'                      
 STORED AS KUDU                   
 TBLPROPERTIES ('kudu.master_addresses'='pro-data-sh003,pro-data-sh004,pro-data-sh005'); 

查看已维护分区

show range partitions ${表名};
-- 示例
show range partitions ods_temp_data;