提供一个HDFS内的文件的路径,对该文件进行创建和删除操作。如果文件所在目录不存在,则自动创建目录。

 1 import java.text.SimpleDateFormat;
 2 
 3 import org.apache.hadoop.fs.FSDataOutputStream;
 4 import org.apache.hadoop.fs.FileStatus;
 5 import org.apache.hadoop.fs.FileSystem;
 6 import org.apache.hadoop.fs.LocatedFileStatus;
 7 import org.apache.hadoop.fs.Path;
 8 import org.apache.hadoop.fs.RemoteIterator;
 9 
10 
11 public class F_CreateAndDel {
12     public static void CreateFile(FSDataOutputStream out,FileSystem fs,Path p_remotepath)
13     {
14         try{
15             out = fs.create(p_remotepath);
16             System.out.println("create successfully");
17         }
18         catch(Exception e)
19         {
20             e.printStackTrace();
21         }
22     }
23     public static void DelFile(FileSystem fs,Path p_remotepath)
24     {
25         try{
26             if(fs.delete(p_remotepath, true))
27             {
28                 System.out.println("del successfully");
29             }
30         }
31         catch(Exception e)
32         {
33             e.printStackTrace();
34         }
35     }
36     public static void main(String arg[])
37     {
38         try{
39             Var_init var = new Var_init();
40             if(!var.fs.exists(var.p_remoteFilePath))
41                 CreateFile(var.out,var.fs,var.p_remoteFilePath);
42             else
43             {
44                 DelFile(var.fs,var.p_remoteFilePath);
45             }
46         }
47         catch(Exception e){
48             e.printStackTrace();
49         }
50     }
51 
52 }

View Code

Var_init类参考 https://www.cnblogs.com/MiraculousB/p/13848744.html