@songlaf
2016-05-19T09:33:05.000000Z
字数 3090
阅读 1455
北风网大数据培训
#文件安装rpm -qa |grep mysqlrpm -e --nodeps mysql-libs-5.1.66-2.el6_3.x86_64rpm -ivh /home/beifeng/MySQL-client-5.6.24-1.el6.x86_64.rpmrpm -ivh /home/beifeng/MySQL-server-5.6.24-1.el6.x86_64.rpm#或者采用yum安装#安装mysql 服务器端:yum install -y mysql-server mysql-devel mysql-libs#安装mysql客户端:yum install mysql#mysql服务管理命令:#启动service mysqld start#自动启动:chkconfig mysqld on#修改登录密码mysqladmin -u root password 123456#登陆mysql -uroot -p123456
cp mysql-connector-java-5.1.27-bin.jar /opt/modules/apache-hive-0.13.1-bin/lib/
#配置HADOOP的目录export HADOOP_HOME=/opt/modules/hadoop-2.5.0#配置HIVE的目录export HIVE_HOME=/opt/modules/apache-hive-0.13.1-bin#增加在PATH增加:$HIVE_HOME/bin
#配置HIVE的目录HIVE_HOME=/opt/modules/apache-hive-0.13.1-bin#增加在PATH增加:$HIVE_HOME/bin
复制hive-env.sh.templaete为hive-env.sh
<!--设置Hadoop的目录-->export HADOOP_HOME=${HADOOP_HOME}<!--设置HIVE的配置目录-->export HIVE_CONF_DIR=$(HIVE_HOME)/conf
复制hive-default.xml.template为hive-site.xml
<property><name>javax.jdo.option.ConnectionURL</name><value>jdbc:mysql://njt.song.s9:3306/metastore?createDatabaseIfNotExist=true</value><description>JDBC连接MySQL字符串</description></property><property><name>javax.jdo.option.ConnectionDriverName</name><value>com.mysql.jdbc.Driver</value><description>Mysql Java驱动</description></property><property><name>javax.jdo.option.ConnectionUserName</name><value>root</value><description>MySQL用户名</description></property><property><name>javax.jdo.option.ConnectionPassword</name><value>123456</value><description>MySQL 密码</description></property>
#登录MySQLmysql -uroot -p123456
mysql> grant all privileges on *.* to root@'njt.song.s6' identified by '123456' ;Query OK, 0 rows affected (0.02 sec)mysql> flush privileges;Query OK, 0 rows affected (0.00 sec)
#当通过Hive把本地数据写入HDFS时,先写到临时目录,最后移动到正式目录bin/hdfs dfs -mkdir /tmp#数据仓库目录bin/hdfs dfs -mkdir -p /user/hive/warehousebin/hdfs dfs -chmod g+w /user/hive/warehousebin/hdfs dfs -chmod g+w /tmp
#注意要首先启动Hadoop,Mapreduce,Yarnbin/hive
#建立数据库create database if not exists song_test_dbcomment 'my test data base'with dbproperties('creator'='song','date'='2016-05-18')#创建表create table Employee(name string,work_place ARRAY<string>,sex_age STRUCT<sex: string, age: int>,skills_score MAP<string, int>,depart_title MAP<STRING, ARRAY<STRING>>)COMMENT 'Employee info'ROW FORMAT DELIMITEDFIELDS TERMINATED BY '|'COLLECTION ITEMS TERMINATED BY ','MAP KEYS TERMINATED BY ':';#Load插入数据LOAD DATA LOCAL INPATH '/home/sjf/employee.txt' OVERWRITE INTO TABLE employee;#数据查询select * from employee

文件employee.txt内容如下
chael| Montreal, Toronto| Male, 30| DB: 80| Product: Developer^DLeadWill| Montreal| Male, 35| Perl: 85| Product: Lead, Test: LeadShelley| New York| Female, 27| Python: 80| Test: Lead, COE: ArchitectLucy| Vancouver| Female, 57| Sales: 89, HR: 94| Sales: LeadLOAD DATA LOCAL INPATH '/home/sjf/employee.txt' OVERWRITE INTO TABLE Employee;