hadoop 在hdfs中读写文件

写文件：

 

 

[java] view plaincopy

1. //指定configuration   
2. Configuration config = new Configuration();   
3. String time = String.valueOf(end-start);   
4. FileSystem fs = FileSystem.get(URI.create("ListStatus"),config);   
5. OutputStream out = fs.create(new Path("/user/student/data/time.txt")); out.write(time.getBytes());   

 

读文件：

 

[java] view plaincopy

1. //指定configuration   
2. Configuration config = new Configuration();   
3. //定义一个DataInputStream   
4. FSDataInputStream indic = null;   
5. ArrayList dictionary = new ArrayList();   
6. FileSystem fs = FileSystem.get(URI.create("ListStatus"),config);   
7. indic = fs.open(new Path("dic/xxx.txt"));   
8. String t = indic.readLine();   
9. while (t != null) {   
10.      dictionary.add(t);   
11.      t = indic.readLine();   
12. }