创建hive数据库:
create database if not exists ccmovies;
查看数据库是否创建成功:
show databases;
创建hive表:
先切换到对应的数据库:
use ccmovies;
建相关表(与文件名相对应,列名与上传的文件中列名相同):
因为需要上传相关csv文件故添加了括号后的内容
CREATE TABLE ccmovies.movies(
movieId String,title String,genres String
) row format serde 'org.apache.hadoop.hive.serde2.OpenCSVSerde' with SERDEPROPERTIES ("separatorChar"=",") STORED AS TEXTFILE;
CREATE TABLE ccmovies.links(
movieId String,imdbId String,tmdbId String
) row format serde 'org.apache.hadoop.hive.serde2.OpenCSVSerde' with SERDEPROPERTIES ("separatorChar"=",") STORED AS TEXTFILE;
CREATE TABLE ccmovies.ratings(
userId String,movieId String,rating String,time String
)row format serde 'org.apache.hadoop.hive.serde2.OpenCSVSerde' with SERDEPROPERTIES("separatorChar"=",") STORED AS TEXTFILE;
create table ccmovies.tags(
userId string,movieId string,tag string,time string
)row format serde 'org.apache.hadoop.hive.serde2.OpenCSVSerde' with SERDEPROPERTIES("separatorChar"=",")STORED AS TEXTFILE;
查看相关表是否创建成功:
show tables;
上传数据到对应的hive表中:
load data inpath '/cc-movies/movies.csv'(hdfs路径) overwrite into table ccmovies.movies; load data inpath '/cc-movies/links.csv' (hdfs路径)overwrite into table ccmovies.links; load data inpath '/cc-movies/ratings.csv' (hdfs路径)overwrite into table ccmovies.ratings; load data inpath '/cc-movies/tags.csv' (hdfs路径)overwrite into table ccmovies.tags;



