1. 刪除分區ide
ALTER TABLE dms.tracklog_5min DROP PARTITION(DAY='${today}');
ALTER TABLE table_name DROP IF EXISTS PARTITION(dt='2018-01-01', game_code='gcol')oop
2.1. 添加分區 編碼
alter table dms.tracklog_5min add partition(day='${today}') location '/dw/dms/tracklog_5min/day=${today}';
目錄爲hdfs的目錄時,目錄中若有數據會自動加載,不存在hive自動建立。
use db; alter table table_name add if not exists partition(day=${logdate}) location ‘dir’;spa
2.2. load已有數據到hive分區中code
LOAD DATA INPATH '/dw/ods/flumelck/day=20151111/lck.1447234402226.gz' INTO TABLE ods.flumelck PARTITION (day='20151111');
分區存在則追加數據,不存在則新建分區。
2.3. 若是需重寫該分區則加overwriteorm
LOAD DATA INPATH '/dw/ods/flumelck/day=20151111/lck.1447235127866.gz' overwrite INTO TABLE ods.flumelck PARTITION (day='20151112');hadoop
注意:若是load的hdfs目錄與分區目錄不一致,則會mv數據到分區目錄中。ci
3. 刪除表
Drop table DROP TABLE [IF EXISTS] table_name; string
4. 建內部表it
use lhc;
#drop table dw_wide_site;
create table dw_wide_site(
`siteNo` STRING COMMENT '新建站點時系統分配的站點惟一編號',
`siteBusinessNo` STRING COMMENT '站點業務編碼',
`siteName` STRING COMMENT '站點名稱',
`siteType` SMALLINT COMMENT '站點類型,0可發貨 1可提貨 ^^',
`province` STRING COMMENT '站點所在省份',
`city` STRING COMMENT '站點所在城市',
`county` STRING COMMENT '站點所在區縣',
`address` STRING COMMENT '站點地址',
`lnglat` DOUBLE COMMENT '經度,緯度',
`leaderName` STRING COMMENT '負責人姓名',
`leaderContact` STRING COMMENT '負責人聯繫方式',
`enterpriseName` STRING COMMENT '歸屬企業名稱',
`deptNo` STRING COMMENT '部門編號',
`createTime` STRING COMMENT '站點建立日期',
`updateTime` STRING COMMENT '站點基本信息的更新日期'
)
COMMENT '站點信息 部分數據根據訂單數據逐日統計產生。'
PARTITIONED BY (
`ymd` string)
row format delimited
FIELDS TERMINATED BY '\;'
LINES TERMINATED BY '\n'
;
hadoop fs -cat /user/hive/warehouse/original.db/t_yundan_info/t_yundan_info.txt |morehadoop fs -ls /user/hive/warehouse/lhc.db/hadoop fs -mkdir /user/hive/warehouse/lhc.db/dw_wide_site/