Hadoop Java API 操作 hdfs--1

Hadoop文件系统是一个抽象的概念，hdfs仅仅是Hadoop文件系统的其中之一。

就hdfs而言，访问该文件系统有两种方式：（1）利用hdfs自带的命令行方式，此方法类似linux下面的shell命令；（2）利用hdfs的java接口，通过编写java程序来实现。

 操作环境：hadoop-1.0.4，java1.7.0_65，Ubuntu 14.04.1 LTS

 1 import java.io.InputStream;
 2 import java.net.URI;
 3 
 4 import org.apache.hadoop.conf.Configuration;
 5 import org.apache.hadoop.fs.FSDataInputStream;
 6 import org.apache.hadoop.fs.FileSystem;
 7 import org.apache.hadoop.fs.Path;
 8 import org.apache.hadoop.io.IOUtils;
 9 
10 
11 
12 
13 public class FileSystemCat {
14 
15         public static void main(String[] args) throws Exception {
16                 String uri = args[0];
17                 Configuration conf = new Configuration();
18                 FileSystem fs = FileSystem.get(URI.create(uri), conf);
19                 InputStream in = null;
20                 try {
21                         in = fs.open(new Path(uri));
22                         IOUtils.copyBytes(in, System.out, 4096, false);
23                 } finally {
24                         IOUtils.closeStream(in);
25                 }
26         }
27 
28 }

View Code