前哨站/命令速查
命令速查

命令速查

按场景分组,实验时对着敲就能把环境跑起来。

集群启停

启动 HDFS

SHELL
start-dfs.sh

启动 YARN

SHELL
start-yarn.sh

一键启动(Hadoop 3)

SHELL
start-all.sh

停止集群

SHELL
stop-dfs.sh && stop-yarn.sh

查看进程

SHELL
jps

HDFS 状态

SHELL
hdfs dfsadmin -report

安全模式

SHELL
hdfs dfsadmin -safemode get / leave

HA 状态与切换

SHELL
hdfs haadmin -getServiceState nn1
hdfs haadmin -failover nn1 nn2

ZooKeeper

启动/停止

SHELL
zkServer.sh start / stop

查状态

SHELL
zkServer.sh status

客户端

SHELL
zkCli.sh -server hadoop1:2181

HDFS 常用

列目录 / 建目录

SHELL
hdfs dfs -ls -h /
hdfs dfs -mkdir -p /data/input

上传 / 下载

SHELL
hdfs dfs -put w.txt /data/input/
hdfs dfs -get /data/input/w.txt ./

查看 / 大小

SHELL
hdfs dfs -cat /data/input/w.txt
hdfs dfs -du -h /data

权限 / 属主

SHELL
hdfs dfs -chmod -R 777 /data
hdfs dfs -chown -R hadoop:hadoop /data

删除 / 回收站

SHELL
hdfs dfs -rm -r /data/input
hdfs dfs -expunge

块与校验

SHELL
hdfs fsck / -files -blocks -locations
hdfs fsck / -list-corruptfileblocks

MapReduce

提交作业

SHELL
hadoop jar wc.jar com.demo.WcDriver /wc/input /wc/output

查看结果

SHELL
hdfs dfs -cat /wc/output/part-r-00000

常用调优参数

TEXT
mapreduce.map.memory.mb=2048
mapreduce.reduce.memory.mb=4096
mapreduce.job.reduces=4
mapreduce.map.output.compress=true

Hive

启动与验证

SHELL
hive
hive -e "show databases;"
schematool -initSchema -dbType mysql

常用 HiveQL

SQL
CREATE DATABASE school;
USE school;
SHOW TABLES;
DESC FORMATTED student_info;
SELECT count(*) FROM student_info;

UDF 注册

SQL
ADD JAR /user/hadoop/jars/myudf.jar;
CREATE TEMPORARY FUNCTION my_lower AS 'com.demo.MyLowerUDF';

Sqoop 导入导出

SHELL
sqoop import --connect jdbc:mysql://hadoop1:3306/nev --username root --password 123456 --table weather --hive-import --hive-database ods --hive-table weather_ods -m 1

HBase

启停

SHELL
start-hbase.sh / stop-hbase.sh

进入 shell

SHELL
hbase shell

常用命令

SHELL
create 'student', 'info'
put 'student','1001','info:name','张三'
get 'student','1001'
scan 'student'
count 'student'
disable 'student' && drop 'student'

Phoenix

SHELL
sqlline.py hadoop1:2181

Spark

启动

SHELL
$SPARK_HOME/sbin/start-all.sh

提交作业

SHELL
spark-submit --master yarn --class com.demo.Wc wc.jar hdfs:///input hdfs:///out

常用算子

TEXT
map / flatMap / filter / reduceByKey / groupByKey / join
count / collect / first / take / reduce / saveAsTextFile