主页 > 新闻资讯 > 大数据培训:Hive表的基本操作

大数据培训:Hive表的基本操作

作者:张老师 浏览次数: 2021-03-16 17:42
针对于Hive表的操作,是Hive当中需要大家付出足够的精力去学习和掌握的。Hive所支持的类SQL语言HQL,如果自身有比较好的SQL基础的话,其实很多东西也是能够快速融会贯通的。今天的大数据培训分享,我们就来讲讲Hive表的基本操作。

大数据培训:Hive表的基本操作

Hive创建表

create table语句遵从sql语法习惯,只不过Hive的语法更灵活。例如,可以定义表的数据文件存储位置,使用的存储格式等。

create table if not exists test.user1(
name string comment 'name',
salary float comment 'salary',
address struct<country:string, city:string> comment 'home address'
)
comment 'description of the table'
partitioned by (age int)
row format delimited fields terminated by '\t'
stored as orc;

没有指定external关键字,则为管理表,跟mysql一样,if not exists如果表存在则不做操作,否则则新建表。comment可以为其做注释,分区为age年龄,列之间分隔符是\t,存储格式为列式存储orc,存储位置为默认位置,即参数hive.metastore.warehouse.dir(默认:/user/hive/warehouse)指定的hdfs目录。

Hive拷贝表

使用like可以拷贝一张跟原表结构一样的空表,里面是没有数据的。

create table if not exists test.user2 like test.user1;

Hive查看表结构

通过desc [可选参数] tableName命令查看表结构,可以看出拷贝的表test.user1与原表test.user1的表结构是一样的。

hive> desc test.user2;
OK
name                    string                  name               
salary                  float                   salary             
address                 struct<country:string,city:string>  home address       
age                     int                                        

# Partition Information        
# col_name                data_type               comment            

age                     int                                        

也可以加formatted,可以看到更加详细和冗长的输出信息。

hive> desc formatted test.user2;
OK
# col_name                data_type               comment            

name                    string                  name               
salary                  float                   salary             
address                 struct<country:string,city:string>  home address       

# Partition Information        
# col_name                data_type               comment            

age                     int                                        

# Detailed Table Information        
Database:               test                    
Owner:                  hdfs                    
CreateTime:             Mon Dec 21 16:37:57 CST 2020    
LastAccessTime:         UNKNOWN                 
Retention:              0                       
Location:               hdfs://nameservice2/user/hive/warehouse/test.db/user2   
Table Type:             MANAGED_TABLE           
Table Parameters:        
    COLUMN_STATS_ACCURATE   {\"BASIC_STATS\":\"true\"}
    numFiles                0                  
    numPartitions           0                  
    numRows                 0                  
    rawDataSize             0                  
    totalSize               0                  
    transient_lastDdlTime   1608539877         

# Storage Information        
SerDe Library:          org.apache.hadoop.hive.ql.io.orc.OrcSerde   
InputFormat:            org.apache.hadoop.hive.ql.io.orc.OrcInputFormat 
OutputFormat:           org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat    
Compressed:             No                      
Num Buckets:            -1                      
Bucket Columns:         []                      
Sort Columns:           []                      
Storage Desc Params:        
    field.delim             \t                 
    serialization.format    \t                 

Hive删除表

这跟sql中删除命令drop table是一样的:

drop table if exists table_name;

对于管理表(内部表),直接把表彻底删除了;对于外部表,还需要删除对应的hdfs文件才会彻底将这张表删除掉,为了安全,通常hadoop集群是开启回收站功能的,删除外表表的数据就在回收站,后面如果想恢复也是可以恢复的,直接从回收站mv到hive对应目录即可。

Hive修改表

大多数表属性可以通过alter table来修改。

①表重命名

alter table test.user1 rename to test.user3;

②增、修、删分区

增加分区使用命令alter table table_name add partition(...) location hdfs_path

alter table test.user2 add if not exists
partition (age = 101) location '/user/hive/warehouse/test.db/user2/part-0000101'
partition (age = 102) location '/user/hive/warehouse/test.db/user2/part-0000102'

修改分区也是使用alter table ... set ...命令

alter table test.user2 partition (age = 101) set location '/user/hive/warehouse/test.db/user2/part-0000110'
删除分区命令格式是alter table tableName drop if exists partition(...)

alter table test.user2 drop if exists partition(age = 101)

③修改列信息

可以对某个字段进行重命名,并修改位置、类型或者注释:

修改前:

hive> desc user_log;
OK
userid                  string                                     
time                    string                                     
url                     string                                     

修改列名time为times,并且使用after把位置放到url之后,本来是在之前的。

alter table test.user_log
change column time times string
comment 'salaries'
after url;

再来看表结构:

hive> desc user_log;
OK
userid                  string                                     
url                     string                                     
times                   string                  salaries           
time -> times,位置在url之后。

④增加列

hive也是可以添加列的:

alter table test.user2 add columns (
birth date comment '生日',
hobby string comment '爱好'
);

⑤删除列

删除列不是指定列删除,需要把原有所有列写一遍,要删除的列排除掉即可:

hive> desc test.user3;
OK
name                    string                  name               
salary                  float                   salary             
address                 struct<country:string,city:string>  home address       
age                     int                                        

# Partition Information        
# col_name                data_type               comment            

age                     int                                        

如果要删除列salary,只需要这样写:

alter table test.user3 replace columns(
name string,
address struct<country:string,city:string>
);

这里会报错:

FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. Replacing columns cannot drop columns for table test.user3. SerDe may be incompatible

这张test.user3表是orc格式的,不支持删除,如果是textfile格式,上面这种replace写法是可以删除列的。通常情况下不会轻易去删除列的,增加列倒是常见。

⑥修改表的属性

可以增加附加的表属性,或者修改属性,但是无法删除属性:

alter table tableName set tblproperties(
    'key' = 'value'
);

举例:这里新建一张表:

create table t8(time string,country string,province string,city string)
row format delimited fields terminated by '#'
lines terminated by '\n'
stored as textfile;

这条语句将t8表中的字段分隔符'#'修改成'\t';

alter table t8 set serdepropertyes('field.delim'='\t');

关于大数据培训,Hive表的基本操作,以上就为大家做了基本的介绍了。建议大家在学习的时候,可以结合到SQL来记忆,很多地方其实是差不多的,但是HQL会更加适用于Hadoop生态下的查询需求。成都加米谷大数据,专业大数据培训机构,大数据开发,数据分析与挖掘,零基础就业班本月正在招生中,课程大纲及学习视频可联系客服获取!
热点排行
推荐文章
立即申请>>