HDFS的API
此文档用来提醒自己编写API的步骤
1.获取与服务器集群上HDFS的连接
a.获取环境变量Configuration conf=new Configuration();
b.获取HDFs 文件系统
**FileSystem fs=FileSystem.get(new****URI("hdfs://192.168.234.214:9000"),conf);**** **
2.下载文件到本地(输入输出流对接)
a.获取输入流,打开文件InputStream in=fs.open(new Path(“/park/1.txt”));
b.获取输出流,创建本地文件准备存放hdfs数据
c.输入输出流对接,拿到文件
d.关流
** 3.上传本地文件到HDFS**
同2 输入输出流对接
4.利用copyFromLocalFile/copyToLocalFile完成上传和下载
//copyFromLocalFile:本地=》HDFS第一个path:本地文件路径
copyFromLocalFile(new Path(“2.txt”),new Path(“/park/2.txt”));
//copyToLocalFile:HDFS=》本地第一path:HDFS的文件路径
fs.copyToLocalFile(new Path(“/park/2.txt”),new Path(“2.txt”));
5.创建 fs.mkdir()
6.删除 fs.delete(目录,boolean)
7.查看 fs.listStatus(new Path(“/park01”));
……..
还没有评论,来说两句吧...