Hadoop HDFS编程 API入门系列之HdfsUtil版本1

Posted 2020-08-23 大数据和人工智能躺过的坑

 

　　不多说，直接上代码。

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

代码

 1 package zhouls.bigdata.myWholeHadoop.HDFS.hdfs2;
 2 
 3 import java.io.FileOutputStream;
 4 import java.io.IOException;
 5 
 6 import org.apache.commons.io.IOUtils;
 7 import org.apache.hadoop.conf.Configuration;
 8 import org.apache.hadoop.fs.FSDataInputStream;
 9 import org.apache.hadoop.fs.FileSystem;
10 import org.apache.hadoop.fs.Path;
11 
12 public class HdfsUtil {
13 
14     
15     public static void main(String[] args) throws IOException {
16         
17         // to upload a file to hdfs
18         
19         Configuration conf = new Configuration();
20         
21         FileSystem fs = FileSystem.get(conf);
22         
23         Path src = new Path("hdfs://HadoopMaster:9000/jdk-7u65-linux-i586.tar.gz");
24         
25         FSDataInputStream in = fs.open(src);
26         
27         FileOutputStream os = new FileOutputStream("/home/hadoop/download/jdk.tgz");
28         
29         IOUtils.copy(in, os);        
30     }    
31 }