Hive 简单操做

 

a，建立无分区表

CREATE TABLE IF NOT EXISTS student(id int COMMENT '学号，主键惟一',name String COMMENT '姓名')
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
LINES TERMINATED BY '\n'
STORED AS TEXTFILE;

b，数据录入方式

本地系统数据录入方式

LOAD DATA LOCAL INPATH '/home/hadoop/software/hive/student.txt' INTO TABLE student；

HDFS系统文件录入方式

LOAD DATA INPATH '/data/student.txt' INTO TABLE student;

c、

查看全部的hive表
show tables;

查看表结构
decribe wordcount;

删除表
DROP TABLE IF EXISTS wordcount;

表重命名
alter table wordcount rename to sb;

增长字段
alter table wordcount add columns (count int);

d，数据导出操做

将hive中的数据导出到Hdfs
insert overwrite directory '/lwj/hive_out' select w.* from wordcount w;

将hive中的数据导出到local
insert overwrite local directory '/lwj/hive_out' select w.* from wordcount w;

根据条件导出数据到local，并设置导出数据间的分隔符，好比','分隔
insert overwrite local directory '/opt/software/hive/hive_out'
row format delimited
FIELDS TERMINATED BY ','
COLLECTION ITEMS TERMINATED BY ','
MAP KEYS TERMINATED BY ':'
select userid,cntFollowing,cntFollowers from user_test where entitySectionUrn=195861L;

e，建立映射表，hive与hbase结合

CREATE EXTERNAL TABLE u_data (   userUrn string,   userId string,   screenName string)   STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' WITH SERDEPROPERTIE(   "hbase.columns.mapping" = ":key,info:userId,info:screenName",   "hbase.table.default.storage.type" = "binary"   )    TBLPROPERTIES ("hbase.table.name" = "bvuser");